cooldaemon / rabbitfoot Goto Github PK

After consuming a message from the first connection, I'm trying to create a new connection to a second RabbitMQ server in the callback and it hangs when calling Net::RabbitFoot->new()->load_xml_spec()->connect();
The RabbitMQ logs report: {handshake_timeout,handshake}

Hiya.

If you're connected to a RabbitMQ server, and the server unexpectedly goes away, then the on_failure callback to ->connect in AnyEvent::RabbitMQ is called.

This is passed by _do in Net::RabbitFoot and is a coro rouse_cb. However that is only used for checking the connection works, and so later when it is called back to, it has no effect.

I would have expected one of the on_close, or on_failure callbacks I'd passed to the connect method to be called instead, as I'd like to be able to handle reconnecting automatically if the connection to the server is interrupted in long running processes.

Cheers
t0m

Hiya.

Can you release this to CPAN, or at least tag a version in git so that I can build a company internal package for a specific numbered version?

Thanks in advance.