# 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