API 관련 수정
This commit is contained in:
@@ -29,7 +29,7 @@ class NaverWorker extends BaseCommand
|
||||
while (true) {
|
||||
// 메인 큐 및 재시도 큐에서 데이터 꺼내기 (Blocking Pop, 5초 타임아웃)
|
||||
// LIFO (lPush/brPop) 사용 시: ['naver:queue:retry', 'naver:queue']
|
||||
$item = $redis->brPop(['naver:queue'], 5);
|
||||
$item = $redis->brPop(['naver:worker_queue'], 5);
|
||||
|
||||
if ($item) {
|
||||
$payload = json_decode($item[1], true);
|
||||
|
||||
Reference in New Issue
Block a user