[rabbitmq-discuss] BUG: Failing nodes with HA-queue stops message flow

Matthias Radestock matthias at rabbitmq.com
Mon Oct 1 15:22:57 BST 2012


Simon,

On 01/10/12 15:07, Simon Lundström wrote:
> I have no idea how *I* should be handling consumer cancel notification
> (can't find this in the documentation), but I'm pretty sure Ruby AMQP
> handles it, see
> <https://github.com/ruby-amqp/amq-client/commit/49951878a8ff4bdbcead3c13eb7737ade6e70669>
> and <https://groups.google.com/forum/#!topic/ruby-amqp/KKxv4DFVJVk>.

It *supports* CCNs, but I am pretty sure you'll need to set up a call 
back to actually *handle* them (i.e. re-consume).

> How can I see the client properties (to check if my consumer reports
> support for CCN) in the management GUI?

They should be shown on the connection details page.

> Under Connections => Consumer IP, Client properties I only get:
> information http://github.com/ruby-amqp/amqp
> platform  ruby 1.8.7 (2012-02-08 patchlevel 358) [universal-darwin11.0]
> version 0.9.7
> product AMQP gem

I suspect your version of the gem is too old.

> I'll ask on their mailinglist.

Good idea.

> Aaah, and the reason for this not happening when disk01 is master and
> then restarted is because the consumer is connected to disk01 and must
> reconnect (because it just lost the connection)?

Correct.

> Oh, why mailed here in the first place was becuase Emile thought it was
> strange that ram01 threw this message:
> =ERROR REPORT==== 1-Oct-2012::13:55:35 ===
> Discarding message {'$gen_call',{<0.173.0>,#Ref<0.0.0.967>},{notify_down,<6733.320.0>}} from <0.173.0> to <0.200.0> in an old incarnation (1) of this node (2)

I don't think that indicates a problem.

> But maybe that's when the consumer doesn't handle basic.cancel?

Nah, definitely unrelated to that.


Regards,

Matthias.


More information about the rabbitmq-discuss mailing list