Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
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
You can’t perform that action at this time.