Skip to content

Instantly share code, notes, and snippets.

@kennethkalmer
Created May 6, 2011 08:06
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save kennethkalmer/958594 to your computer and use it in GitHub Desktop.
diff --git a/lib/ruote-amqp/participant.rb b/lib/ruote-amqp/participant.rb
index f6aa9c2..25bf604 100644
--- a/lib/ruote-amqp/participant.rb
+++ b/lib/ruote-amqp/participant.rb
@@ -120,8 +120,6 @@ module RuoteAMQP
#
def initialize(options)
- RuoteAMQP.start!
-
@options = {
'queue' => nil,
'forget' => false,
@@ -139,6 +137,8 @@ module RuoteAMQP
#
def consume(workitem)
+ RuoteAMQP.start!
+
target_queue = determine_queue(workitem)
raise 'no queue specified (outbound delivery)' unless target_queue
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment