Do not need to pass :consumer_tag in Queue#unsubscribe call because i…

…t will be picked up from @subscription
ruby-amqp · Sep 17, 2009 · 79337d2 · 79337d2
1 parent 0358561
commit 79337d2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/qrack/subscription.rb b/lib/qrack/subscription.rb
@@ -54,7 +54,7 @@ def start(&blk)
 				begin
 					method = client.next_method(:timeout => timeout)
 				rescue Qrack::ClientTimeout
-					queue.unsubscribe(:consumer_tag => consumer_tag)
+					queue.unsubscribe()
 					break
 				end
 
@@ -78,7 +78,7 @@ def start(&blk)
 
 				# Exit loop if message_max condition met
 				if (!message_max.nil? and message_count == message_max)
-					queue.unsubscribe(:consumer_tag => consumer_tag)
+					queue.unsubscribe()
 					break
 				end