|
@@ -24,6 +24,7 @@ class Mq{
|
|
|
//一对一
|
|
//一对一
|
|
|
|
|
|
|
|
try{
|
|
try{
|
|
|
|
|
+ Log::debug('mq start {channel} {message}',['channel'=>$channelName,'message'=>$message]);
|
|
|
$host = config("queue.connections.rabbitmq.host");
|
|
$host = config("queue.connections.rabbitmq.host");
|
|
|
$port = config("queue.connections.rabbitmq.port");
|
|
$port = config("queue.connections.rabbitmq.port");
|
|
|
$user = config("queue.connections.rabbitmq.user");
|
|
$user = config("queue.connections.rabbitmq.user");
|
|
@@ -114,6 +115,7 @@ class Mq{
|
|
|
}
|
|
}
|
|
|
}catch(\Exception $e){
|
|
}catch(\Exception $e){
|
|
|
// push to issues
|
|
// push to issues
|
|
|
|
|
+ Log::error('mq worker exception',$e);
|
|
|
$channelName = 'issues';
|
|
$channelName = 'issues';
|
|
|
$channelIssues = $connection->channel();
|
|
$channelIssues = $connection->channel();
|
|
|
$channelIssues->queue_declare($channelName, false, true, false, false);
|
|
$channelIssues->queue_declare($channelName, false, true, false, false);
|
visuddhinanda