Argh that was it. Yeah i was starting a new listener each time I started a workflow. I moved that line to the initializer and the problem was solved. Thanks!
On Mar 9, 6:29 pm, John Mettraux <[email protected]> wrote: > 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
