-
Notifications
You must be signed in to change notification settings - Fork 46
Open
Description
I would like to implement the RPC use case on rabbitmq as described https://www.rabbitmq.com/direct-reply-to.html . but when executing the consume on the "amq.rabbitmq.reply-to", an exception is thrown
Execution error (ShutdownSignalException) at com.rabbitmq.client.impl.ChannelN/asyncShutdown (ChannelN.java:517).
channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - reply consumer cannot acknowledge, class-id=60, method-id=20)
It looks like the langohr library does not pass the no-ack option to rabbitmq api.
here is the consuming code:
(lc/subscribe channel "amq.rabbitmq.reply-to" rpc-handler {:no-ack false})
thanks for you help
Metadata
Metadata
Assignees
Labels
No labels