修改队列

app/Console/Commands/SyncSupplierToErp.php

@@ -52,10 +52,10 @@ class SyncSupplierToErp extends Command
         $syncService = new SyncSupplierService();
         $syncService = new SyncSupplierService();
         $success = 0;
         $success = 0;
         $count = 0;
         $count = 0;
-        $conn = new AMQPStreamConnection(config('database.connections.rabbitmq.host'),
-            config('database.connections.rabbitmq.port'),
-            config('database.connections.rabbitmq.login'),
-            config('database.connections.rabbitmq.password'));
+        $conn = new AMQPStreamConnection(config('database.connections.rabbitmq2.host'),
+            config('database.connections.rabbitmq2.port'),
+            config('database.connections.rabbitmq2.login'),
+            config('database.connections.rabbitmq2.password'));
         foreach ($suppliers as $supplier) {
         foreach ($suppliers as $supplier) {
             $count++;
             $count++;
             $supplierId = $supplier->supplier_id;
             $supplierId = $supplier->supplier_id;

app/Http/Services/SyncSupplierService.php

@@ -146,10 +146,10 @@ class SyncSupplierService
         if ($conn) {
         if ($conn) {
         } else {
         } else {
             $conn = new AMQPStreamConnection(
             $conn = new AMQPStreamConnection(
-                config('database.connections.rabbitmq.host'),
-                config('database.connections.rabbitmq.port'),
-                config('database.connections.rabbitmq.login'),
-                config('database.connections.rabbitmq.password')
+                config('database.connections.rabbitmq2.host'),
+                config('database.connections.rabbitmq2.port'),
+                config('database.connections.rabbitmq2.login'),
+                config('database.connections.rabbitmq2.password')
             );
             );
         }
         }
         $channel = $conn->channel();
         $channel = $conn->channel();