# File lib/mq.rb, line 797
  def reset
    @deferred_status = nil
    @channel = nil
    initialize @connection

    @consumers = {}

    exs = @exchanges
    @exchanges = {}
    exs.each{ |_,e| e.reset } if exs

    qus = @queues
    @queues = {}
    qus.each{ |_,q| q.reset } if qus

    prefetch(@prefetch_size) if @prefetch_size
  end