Wait to unsubscribe until Basic.CancelOk is received

ruby-amqp · Dec 8, 2009 · 893248c · 893248c
1 parent 9245cc9
commit 893248c
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/lib/mq/queue.rb b/lib/mq/queue.rb
@@ -336,7 +336,6 @@ def subscribe opts = {}, &blk
     # method it will raise a channel or connection exception.
     #
     def unsubscribe opts = {}, &blk
-      @on_msg = nil
       @on_cancel = blk
       @mq.callback{
         @mq.send Protocol::Basic::Cancel.new({ :consumer_tag => @consumer_tag }.merge(opts))