diff --git a/centrifugo/app/config/queue.php b/centrifugo/app/config/queue.php index b0ac76d..e698209 100644 --- 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 index b0ac76d..e698209 100644 --- 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 index b0ac76d..e698209 100644 --- 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 index 3349827..abb0dd7 100644 --- 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 index 9c99e30..14ae780 100644 --- 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', ...), - // ], - ], ], ],