Fix problem with initialization roadrunner queue pipelines

spiral · May 31, 2023 · d6d0ef5 · d6d0ef5
1 parent 59b01d3
commit d6d0ef5
Show file tree

Hide file tree

Showing 5 changed files with 40 additions and 69 deletions.
diff --git a/centrifugo/app/config/queue.php b/centrifugo/app/config/queue.php
@@ -23,6 +23,13 @@
         // 'rating-queue' => 'sync',
     ],
 
+    'pipelines' => [
+        'local' => [
+            'connector' => new MemoryCreateInfo('local'),
+            'consume' => true,
+        ],
+    ],
+
     /**
      * Queue connections
      * Drivers: "sync", "roadrunner"
@@ -35,12 +42,6 @@
         'roadrunner' => [
             'driver' => 'roadrunner',
             'default' => 'local',
-            'pipelines' => [
-                'local' => [
-                    'connector' => new MemoryCreateInfo('local'),
-                    'consume' => true,
-                ],
-            ],
         ],
     ],
 

diff --git a/cinema/app/config/queue.php b/cinema/app/config/queue.php
@@ -23,6 +23,13 @@
         // 'rating-queue' => 'sync',
     ],
 
+    'pipelines' => [
+        'local' => [
+            'connector' => new MemoryCreateInfo('local'),
+            'consume' => true,
+        ],
+    ],
+
     /**
      * Queue connections
      * Drivers: "sync", "roadrunner"
@@ -35,12 +42,6 @@
         'roadrunner' => [
             'driver' => 'roadrunner',
             'default' => 'local',
-            'pipelines' => [
-                'local' => [
-                    'connector' => new MemoryCreateInfo('local'),
-                    'consume' => true,
-                ],
-            ],
         ],
     ],
 

diff --git a/payment/app/config/queue.php b/payment/app/config/queue.php
@@ -23,6 +23,13 @@
         // 'rating-queue' => 'sync',
     ],
 
+    'pipelines' => [
+        'local' => [
+            'connector' => new MemoryCreateInfo('local'),
+            'consume' => true,
+        ],
+    ],
+
     /**
      * Queue connections
      * Drivers: "sync", "roadrunner"
@@ -35,12 +42,6 @@
         'roadrunner' => [
             'driver' => 'roadrunner',
             'default' => 'local',
-            'pipelines' => [
-                'local' => [
-                    'connector' => new MemoryCreateInfo('local'),
-                    'consume' => true,
-                ],
-            ],
         ],
     ],
 

diff --git a/users/app/config/queue.php b/users/app/config/queue.php
@@ -23,6 +23,14 @@
         // 'rating-queue' => 'sync',
     ],
 
+
+    'pipelines' => [
+        'memory' => [
+            'connector' => new MemoryCreateInfo('local'),
+            'consume' => true,
+        ],
+    ],
+
     /**
      * Queue connections
      * Drivers: "sync", "roadrunner"
@@ -35,30 +43,6 @@
         'roadrunner' => [
             'driver' => 'roadrunner',
             'default' => 'memory',
-            'pipelines' => [
-                'memory' => [
-                    'connector' => new MemoryCreateInfo('local'),
-                    // Run consumer for this pipeline on startup (by default)
-                    // You can pause consumer for this pipeline via console command
-                    // php app.php queue:pause local
-                    'consume' => true,
-                ],
-                // 'amqp' => [
-                //     'connector' => new AMQPCreateInfo('bus', ...),
-                //     // Don't consume jobs for this pipeline on start
-                //     // You can run consumer for this pipeline via console command
-                //     // php app.php queue:resume local
-                //     'consume' => false
-                // ],
-                //
-                // 'beanstalk' => [
-                //     'connector' => new BeanstalkCreateInfo('bus', ...),
-                // ],
-                //
-                // 'sqs' => [
-                //     'connector' => new SQSCreateInfo('amazon', ...),
-                // ],
-            ],
         ],
     ],
 

diff --git a/web/app/config/queue.php b/web/app/config/queue.php
@@ -4,9 +4,6 @@
 
 use Spiral\Queue\Driver\SyncDriver;
 use Spiral\RoadRunner\Jobs\Queue\MemoryCreateInfo;
-use Spiral\RoadRunner\Jobs\Queue\AMQPCreateInfo;
-use Spiral\RoadRunner\Jobs\Queue\BeanstalkCreateInfo;
-use Spiral\RoadRunner\Jobs\Queue\SQSCreateInfo;
 use Spiral\RoadRunnerBridge\Queue\Queue;
 
 return [
@@ -23,6 +20,17 @@
         // 'rating-queue' => 'sync',
     ],
 
+
+    'pipelines' => [
+        'memory' => [
+            'connector' => new MemoryCreateInfo('local'),
+            // Run consumer for this pipeline on startup (by default)
+            // You can pause consumer for this pipeline via console command
+            // php app.php queue:pause local
+            'consume' => true,
+        ],
+    ],
+
     /**
      * Queue connections
      * Drivers: "sync", "roadrunner"
@@ -35,30 +43,6 @@
         'roadrunner' => [
             'driver' => 'roadrunner',
             'default' => 'memory',
-            'pipelines' => [
-                'memory' => [
-                    'connector' => new MemoryCreateInfo('local'),
-                    // Run consumer for this pipeline on startup (by default)
-                    // You can pause consumer for this pipeline via console command
-                    // php app.php queue:pause local
-                    'consume' => true,
-                ],
-                // 'amqp' => [
-                //     'connector' => new AMQPCreateInfo('bus', ...),
-                //     // Don't consume jobs for this pipeline on start
-                //     // You can run consumer for this pipeline via console command
-                //     // php app.php queue:resume local
-                //     'consume' => false
-                // ],
-                //
-                // 'beanstalk' => [
-                //     'connector' => new BeanstalkCreateInfo('bus', ...),
-                // ],
-                //
-                // 'sqs' => [
-                //     'connector' => new SQSCreateInfo('amazon', ...),
-                // ],
-            ],
         ],
     ],