|
|
@@ -133,7 +133,8 @@ class Mq
|
|
|
throw new \Exception('task error');
|
|
|
}
|
|
|
} catch (\Exception $e) {
|
|
|
- Log::error('mq worker exception', [
|
|
|
+ Log::error("mq worker {$queue} exception", [
|
|
|
+ 'queue' => $queue,
|
|
|
'message_id' => $message->get('message_id'),
|
|
|
'exception' => $e
|
|
|
]);
|
|
|
@@ -215,8 +216,8 @@ class Mq
|
|
|
try {
|
|
|
$channel->wait(null, false, $timeout);
|
|
|
} catch (AMQPTimeoutException $e) {
|
|
|
- // ignore it
|
|
|
- }
|
|
|
+ // ignore it
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|