delayed job and amqp gem

[phil...@automate-dev.com]

Hi,

I'm currently trying to get the amqp gem working within a Delayed Job.

If I use my client outside delayed job, everything works fine: https://gist.github.com/anonymous/5482005

However I put similar code into a Delayed Job, then I get no errors, but the messages never arrive on the broker.

https://gist.github.com/anonymous/5481975

My guess is that is has something to do with EventMachine, but I'm currently clueless. So any help is very much appreciated.

Thanks in advance,

Philippe

[Michael Klishin]

2013/4/29 <phil...@automate-dev.com>

My guess is that is has something to do with EventMachine, but I'm currently clueless

DelayedJob forks and the child process does not inherit EM thread. So you need to connect in the child process.

This situation is the same as with Unicorn [1]. Reconnecting from fork(2) children would also be necessary with any library that uses

sockets.

1. http://rubyamqp.info/articles/connecting_to_broker/#starting_the_event_loop_and_connecting_in_web_applications_ruby_on_rails_sinatra_merb_rack
--
MK

http://github.com/michaelklishin
http://twitter.com/michaelklishin