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