# File lib/amqp/queue.rb, line 371 def unsubscribe(opts = {}, &blk) @on_cancel = blk @mq.callback { @mq.send Protocol::Basic::Cancel.new({ :consumer_tag => @consumer_tag }.merge(opts)) } self end