diff --git a/scripts/applysmstemp.php b/scripts/applysmstemp.php index af936a0..e354933 100644 --- a/scripts/applysmstemp.php +++ b/scripts/applysmstemp.php @@ -7,13 +7,13 @@ require_once __DIR__ . '/../support/bootstrap.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; use support\Log; use Webman\RedisQueue\Redis; - // 申请新短信模版/营销短信发送 $host = config('cons.mq.host'); $port = config('cons.mq.port'); $user = config('cons.mq.user'); $password = config('cons.mq.password'); $queue = config('cons.mq.queue_t') . '-apply.sms.temp'; + define('AMQP_DEBUG', true); // 防止空闲时间断线必须设置心跳 $connection = new AMQPStreamConnection($host, $port, $user, $password, @@ -57,6 +57,7 @@ use Webman\RedisQueue\Redis; }; $rabbit_channel->basic_consume($queue, '', false, false, false, false, $callback); while ($rabbit_channel->is_consuming()) { + Log::info('apply.sms.temp-MQ准备调用wait'); $rabbit_channel->wait(); } $rabbit_channel->close(); diff --git a/scripts/birthdaygiftsms.php b/scripts/birthdaygiftsms.php index f77546d..7491cc8 100644 --- a/scripts/birthdaygiftsms.php +++ b/scripts/birthdaygiftsms.php @@ -8,7 +8,7 @@ use support\Log; use Webman\RedisQueue\Redis; // 生日有礼 - +define('AMQP_DEBUG', true); $host = config('cons.mq.host'); $port = config('cons.mq.port'); $user = config('cons.mq.user'); @@ -43,6 +43,7 @@ use Webman\RedisQueue\Redis; }; $rabbit_channel->basic_consume($queue, '', false, false, false, false, $callback); while ($rabbit_channel->is_consuming()) { + Log::info('birthday.gift.sms-MQ准备调用wait'); $rabbit_channel->wait(); } $rabbit_channel->close(); diff --git a/scripts/rabborderprint.php b/scripts/rabborderprint.php index 0a035e7..ca362e8 100644 --- a/scripts/rabborderprint.php +++ b/scripts/rabborderprint.php @@ -13,7 +13,7 @@ use support\Log; $user = config('cons.mq.user'); $password = config('cons.mq.password'); $queue = config('cons.mq.queue_t') . '-order.print.queue'; - +define('AMQP_DEBUG', true); // 防止空闲时间断线必须设置心跳 $connection = new AMQPStreamConnection($host, $port, $user, $password, '/', @@ -99,6 +99,7 @@ use support\Log; }; $rabbit_channel->basic_consume($queue, '', false, false, false, false, $callback); while ($rabbit_channel->is_consuming()) { + Log::info('order.print.queue-MQ准备调用wait'); $rabbit_channel->wait(); } $rabbit_channel->close(); diff --git a/scripts/rabbproductupdate.php b/scripts/rabbproductupdate.php index 443e95f..85322da 100644 --- a/scripts/rabbproductupdate.php +++ b/scripts/rabbproductupdate.php @@ -8,7 +8,7 @@ use PhpAmqpLib\Connection\AMQPStreamConnection; use support\think\Db; use support\Log; - +define('AMQP_DEBUG', true); $host = config('cons.mq.host'); $port = config('cons.mq.port'); $user = config('cons.mq.user'); @@ -83,6 +83,7 @@ use support\Log; }; $rabbit_channel->basic_consume($queue, '', false, false, false, false, $callback); while ($rabbit_channel->is_consuming()) { + Log::info('product.info.change.queue-MQ准备调用wait'); $rabbit_channel->wait(); } $rabbit_channel->close();