-
-
Notifications
You must be signed in to change notification settings - Fork 11
Open
Labels
bugSomething isn't workingSomething isn't working
Description
Description
Error when connecting to the rabbitmq queue:
ERROR: Unable to declare consumer pipeline "my_amqp". Reason: Error 'rpc_declare_pipeline: jobs_plugin_declare: expected { character for map value' on tcp://127.0.0.1:6001 []How To Reproduce
I created a CLI application with the "queue" & "road-runner" component.
I decided to connect the rabbitmq queue (to exchange.type=topic).
in the file app/config/queue.php
added the my_amqp array with queue settings to pipelines
...
'my_amqp' => [
'connector' => new AMQPCreateInfo(
'main_queue',
exchange: 'app_events',
exchangeType: Spiral\RoadRunner\Jobs\Queue\AMQP\ExchangeType::Topics,
exchangeDurable: true,
queue: 'test-service',
durable: true,
requeueOnFail: true,
routingKey: 'event.*',
),
'consume' => true
], added rr-amqp to connections.
example: code.tar.gz
Launched ./rr serve
I see in the logs
[2023-11-09T16:56:27.544092+00:00] ERROR: Unable to declare consumer pipeline "my_amqp". Reason: Error 'rpc_declare_pipeline: jobs_plugin_declare: expected { character for map value' on tcp://127.0.0.1:6001 []
[2023-11-09T16:56:27.544311+00:00] ERROR: Unable to declare consumer pipeline "memory". Reason: Error 'rpc_declare_pipeline: pipeline already exists, name: local, driver: memory' on tcp://127.0.0.1:6001 []
[2023-11-09T16:56:27.555059+00:00] ERROR: Unable to declare consumer pipeline "my_amqp". Reason: Error 'rpc_declare_pipeline: jobs_plugin_declare: expected { character for map value' on tcp://127.0.0.1:6001 []Additional Info
| Q | A |
|---|---|
| Framework Version | 3.9.1 |
| PHP version | 8.1.14 |
| Operating system | Debian GNU/Linux 11 (bullseye) |
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working