Hi,
We'd like to have a way to do a basic_nack from our consumer because we have configured a dead letter exchange in the queue from where the consumers gets its messages.

So I'm attaching a patch to do that. The patch is against 7.x-1.1 tag and not 7.x-1.x branch. I could rerolled to that branch if you are interested.

Do you see this patch interesting for other people?

Oscar

CommentFileSizeAuthor
messagebroker-add-nack-exception-and-behaviour.patch1.46 KBomllobet

Comments

georgwaechter’s picture

georgwaechter commented

Hi Oscar,

this sounds useful - especially in conjunction with dead letter exchanges as documented in https://www.rabbitmq.com/dlx.html.

I have slightly modified your code, because "nacking" is amqp specific, so i moved the definition of the exception class into the amqp module. Can you have a look at the latest dev release and check whether it works as expected for you?

(the new dev release should appear in a few hours)

thanks

georg

omllobet’s picture

omllobet commented

Hi Georg,

I'll test the dev version this week and get back to you.

Thanks

Oscar

omllobet’s picture

omllobet commented

Hi Georg,

I've been testing the dev version and it does not work, you need to add

require_once 'message_broker_amqp_exception.inc';

to the file "message_broker_amqp/message_broker_amqp.drush.inc"

Thanks!
Oscar

georgwaechter’s picture

georgwaechter commented
Status: Active » Fixed

Hi Oscar,

ah yes, I forgot this very important line *g sorry.

This is now fixed, the 1.2 version is released.

Georg

Status: Fixed » Closed (fixed)

Automatically closed - issue fixed for 2 weeks with no activity.