On Wed, Mar 10, 2010 at 4:55 AM, Dave @ UPENN <[email protected]> wrote: > > Not sure how many of you are using passenger to run your rails apps, > but I'm having a little problem submitting stuff through amqp. I have > a simple rails app that will start workflows using ruote-amqp. > Everything works fine the first time I submit, but when i try to > submit a second time, i get this error in the logs: > > MQ::Error (already subscribed to the queue): > amqp (0.6.6) lib/mq/queue.rb:319:in `subscribe' > /opt/ruby-enterprise-1.8.7-2009.10/lib/ruby/gems/1.8/gems/ruote- > amqp-2.1.5/lib/ruote-amqp/workitem_listener.rb:62:in `initialize' > app/models/submission.rb:38:in `new' > app/models/submission.rb:38:in `submit_job' > app/controllers/submissions_controller.rb:62:in `create' > app/controllers/submissions_controller.rb:61:in `create' > haml (2.2.20) rails/./lib/sass/plugin/rails.rb:20:in `process' > sinatra (0.9.4) lib/sinatra/base.rb:413:in `forward' > sinatra (0.9.4) lib/sinatra/base.rb:484:in `route_missing' > sinatra (0.9.4) lib/sinatra/base.rb:469:in `route!' > sinatra (0.9.4) lib/sinatra/base.rb:555:in `dispatch!' > > ... > > Again, I only get this when i try to submit for a second time. It > obviously complains that it can't subscribe to the same queue because > it's already subscribed from the first submit. I don't have this > issue when running from mongrel, only passenger. Any ideas what this > could be?? > > workitem_listener:62 shows the code that subscribes to the queue. > AND, here is how I'm calling it in my rails model: > > > models/submission.rb: > > def submit_job > > RuoteAMQP::WorkitemListener.new(RuoteKit.engine) > wfid = RuoteKit.engine.launch(self.process_definition) > > end > > > Am I mis-using the listener here?
Hello, why are you creating a listener ? Isn't it sufficient to just launch the process ? Creating a listener and binding it to the engine belongs to initializers, not to a request-driven action. Best regards, -- John Mettraux - http://jmettraux.wordpress.com -- 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
