# 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