gistfile1.diff

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