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] more options : http://groups.google.com/group/openwferu-users?hl=en
