Excellent! By the way, I can confirm that this patch fixed the issue for me, and ruote/ruote-amqp is now talking to my daemon-kit ruote agent. :)
- E On Tue, May 4, 2010 at 10:46 AM, Kenneth Kalmer <[email protected]>wrote: > On Tue, May 4, 2010 at 3:44 AM, John Mettraux <[email protected]>wrote: > >> The initializer for ruote-amqp's listener looks like >> >> ---8<--- >> def initialize( engine_or_storage, queue = nil ) >> >> @storage = engine_or_storage.respond_to?( :storage ) ? >> engine_or_storage.storage : engine_or_storage >> >> self.class.queue = queue if queue >> >> RuoteAMQP.start! >> >> MQ.queue( self.class.queue, :durable => true ).subscribe do |message| >> if AMQP.closing? >> # Do nothing, we're going down >> else >> workitem = decode_workitem( message ) >> reply( workitem ) >> end >> end >> end >> --->8--- >> >> should be replaced with >> >> ---8<--- >> def initialize( engine_or_storage, queue = nil ) >> >> super( engine_or_storage ) >> >> self.class.queue = queue if queue >> >> RuoteAMQP.start! >> >> MQ.queue( self.class.queue, :durable => true ).subscribe do |message| >> if AMQP.closing? >> # Do nothing, we're going down >> else >> workitem = decode_workitem( message ) >> reply( workitem ) >> end >> end >> end >> --->8--- >> >> That makes a patch for Kenneth. >> > > Accepted and pushed. Working on the daemon-kit side with daustin's fork and > then I'll bump versions on both ends. > > Thanks a lot ! > > Best > > > -- > Kenneth Kalmer > [email protected] > http://opensourcery.co.za > @kennethkalmer > > -- > you received this message because you are subscribed to the "ruote users" > group. > to post : send email to [email protected] > to unsubscribe : send email to > [email protected]<openwferu-users%[email protected]> > more options : http://groups.google.com/group/openwferu-users?hl=en > -- you received this message because you are subscribed to the "ruote users" group. to post : send email to [email protected] to unsubscribe : send email to [email protected] more options : http://groups.google.com/group/openwferu-users?hl=en
