Skip to content

Error when connecting to the rabbitmq queueΒ #97

@realization

Description

@realization

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 []

logs.tar.gz

Additional Info

Q A
Framework Version 3.9.1
PHP version 8.1.14
Operating system Debian GNU/Linux 11 (bullseye)

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions