Commit 8408ff1b by 杨树贤

队列修改

parent 17dd1924
Showing with 4 additions and 4 deletions
...@@ -153,10 +153,10 @@ class SkuService ...@@ -153,10 +153,10 @@ class SkuService
//批量上下架队列 //批量上下架队列
public function batchOffShelfSkuQueue($data) public function batchOffShelfSkuQueue($data)
{ {
$conn = new AMQPStreamConnection(config('database.connections.rabbitmq.host'), $conn = new AMQPStreamConnection(config('database.connections.rabbitmq2.host'),
config('database.connections.rabbitmq.port'), config('database.connections.rabbitmq2.port'),
config('database.connections.rabbitmq.login'), config('database.connections.rabbitmq2.login'),
config('database.connections.rabbitmq.password')); config('database.connections.rabbitmq2.password'));
$channel = $conn->channel(); $channel = $conn->channel();
$channel->queue_declare('lie_footstone_batch_downsku_queue', false, true, false, false); $channel->queue_declare('lie_footstone_batch_downsku_queue', false, true, false, false);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment