streamdal/plumber

rabbitmq x-dead-letter-exchange

ddatsh opened this issue · 2 comments

time="2021-12-14T19:44:23+08:00" level=error msg="unable to complete read for backend 'rabbitmq': unable to create new rabbit consumer: unable to initialize rabbitmq consumer: unable to get initial delivery channel: unable to create new server channel: Exception (406) Reason: \"PRECONDITION_FAILED - inequivalent arg 'x-dead-letter-exchange' for queue 'xxxx' in vhost '/': received none but current is the value 'xxx' of type 'longstr'\"" pkg=plumber

Thank you for the report! We will work on getting dead letter support added for RabbitMQ

@ddatsh Happy to report that plumber v1.0.3 now accepts --queue-arg flags to pass additional arguments to rabbit

Example:

plumber read rabbit --exchange-name events --queue-name myqueue --binding-key \# --queue-durable --queue-arg x-dead-letter-exchange=mydeadletter