debug
This commit is contained in:
@@ -16,7 +16,7 @@ use Webman\RedisQueue\Redis;
|
|||||||
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// define('AMQP_DEBUG', true);
|
define('AMQP_DEBUG', true);
|
||||||
// 防止空闲时间断线必须设置心跳
|
// 防止空闲时间断线必须设置心跳
|
||||||
$connection = new AMQPStreamConnection($host, $port, $user, $password,
|
$connection = new AMQPStreamConnection($host, $port, $user, $password,
|
||||||
'/',
|
'/',
|
||||||
@@ -28,7 +28,7 @@ try {
|
|||||||
60,
|
60,
|
||||||
null,
|
null,
|
||||||
false,
|
false,
|
||||||
30
|
15
|
||||||
);
|
);
|
||||||
$rabbit_channel = $connection->channel();
|
$rabbit_channel = $connection->channel();
|
||||||
$rabbit_channel->queue_declare($queue, false, true, false, false);
|
$rabbit_channel->queue_declare($queue, false, true, false, false);
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ use Webman\RedisQueue\Redis;
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
// 生日有礼
|
// 生日有礼
|
||||||
// define('AMQP_DEBUG', true);
|
define('AMQP_DEBUG', true);
|
||||||
$host = config('cons.mq.host');
|
$host = config('cons.mq.host');
|
||||||
$port = config('cons.mq.port');
|
$port = config('cons.mq.port');
|
||||||
$user = config('cons.mq.user');
|
$user = config('cons.mq.user');
|
||||||
@@ -28,7 +28,7 @@ try {
|
|||||||
60,
|
60,
|
||||||
null,
|
null,
|
||||||
false,
|
false,
|
||||||
30
|
15
|
||||||
);
|
);
|
||||||
$rabbit_channel = $connection->channel();
|
$rabbit_channel = $connection->channel();
|
||||||
$rabbit_channel->queue_declare($queue, false, true, false, false);
|
$rabbit_channel->queue_declare($queue, false, true, false, false);
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ use support\Log;
|
|||||||
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// define('AMQP_DEBUG', true);
|
define('AMQP_DEBUG', true);
|
||||||
// 防止空闲时间断线必须设置心跳
|
// 防止空闲时间断线必须设置心跳
|
||||||
$connection = new AMQPStreamConnection($host, $port, $user, $password,
|
$connection = new AMQPStreamConnection($host, $port, $user, $password,
|
||||||
'/',
|
'/',
|
||||||
@@ -28,7 +28,7 @@ try {
|
|||||||
60,
|
60,
|
||||||
null,
|
null,
|
||||||
false,
|
false,
|
||||||
30
|
15
|
||||||
);
|
);
|
||||||
$rabbit_channel = $connection->channel();
|
$rabbit_channel = $connection->channel();
|
||||||
$rabbit_channel->queue_declare($queue, false, true, false, false, false, [
|
$rabbit_channel->queue_declare($queue, false, true, false, false, false, [
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ use support\think\Db;
|
|||||||
use support\Log;
|
use support\Log;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// define('AMQP_DEBUG', true);
|
define('AMQP_DEBUG', true);
|
||||||
$host = config('cons.mq.host');
|
$host = config('cons.mq.host');
|
||||||
$port = config('cons.mq.port');
|
$port = config('cons.mq.port');
|
||||||
$user = config('cons.mq.user');
|
$user = config('cons.mq.user');
|
||||||
@@ -26,7 +26,7 @@ use support\Log;
|
|||||||
60,
|
60,
|
||||||
null,
|
null,
|
||||||
false,
|
false,
|
||||||
30
|
15
|
||||||
);
|
);
|
||||||
$rabbit_channel = $connection->channel();
|
$rabbit_channel = $connection->channel();
|
||||||
$rabbit_channel->queue_declare($queue, false, true, false, false);
|
$rabbit_channel->queue_declare($queue, false, true, false, false);
|
||||||
|
|||||||
Reference in New Issue
Block a user