class Queue
		
		include AMQP
		
	  attr_reader :name, :client
	  attr_accessor :delivery_tag

	  def initialize(client, name, opts = {})
	    @client = client
	    @opts   = opts
	    @name   = name
	    client.send_frame(
	      Protocol::Queue::Declare.new({ :queue => name, :nowait => true }.merge(opts))
	    )
	  end

	  def pop(opts = {})
	    self.delivery_tag = nil
	    client.send_frame(
	      Protocol::Basic::Get.new({ :queue => name, :consumer_tag => name, :no_ack => !opts.delete(:ack), :nowait => true }.merge(opts))
	    )
	    method = client.next_method
	    return unless method.is_a?(Protocol::Basic::GetOk)

	    self.delivery_tag = method.delivery_tag

	    header = client.next_payload
	    msg    = client.next_payload
	    raise 'unexpected length' if msg.length < header.size

	    msg
	  end

	  def ack
	    client.send_frame(
	      Protocol::Basic::Ack.new(:delivery_tag => delivery_tag)
	    )
	  end

	  def publish(data, opts = {})
	    exchange.publish(data, opts)
	  end

	  def message_count
	    status.first
	  end

	  def consumer_count
	    status.last
	  end
  
	  def status(opts = {}, &blk)
	    client.send_frame(
	      Protocol::Queue::Declare.new({ :queue => name, :passive => true }.merge(opts))
	    )
	    method = client.next_method
	    [method.message_count, method.consumer_count]
	  end

	  def bind(exchange, opts = {})
	    exchange           = exchange.respond_to?(:name) ? exchange.name : exchange
	    bindings[exchange] = opts
	    client.send_frame(
	      Protocol::Queue::Bind.new({ :queue => name, :exchange => exchange, :routing_key => opts.delete(:key), :nowait => true }.merge(opts))
	    )
	  end

	  def unbind(exchange, opts = {})
	    exchange = exchange.respond_to?(:name) ? exchange.name : exchange
	    bindings.delete(exchange)

	    client.send_frame(
	      Protocol::Queue::Unbind.new({
	        :queue => name, :exchange => exchange, :routing_key => opts.delete(:key), :nowait => true }.merge(opts)
	      )
	    )
	  end

	  def delete(opts = {})
			client.queues.delete(name)
			
	    client.send_frame(
	      Protocol::Queue::Delete.new({ :queue => name, :nowait => true }.merge(opts))
	    )
	  end

	private
	  def exchange
	    @exchange ||= Exchange.new(client, :direct, '', :key => name)
	  end

	  def bindings
	    @bindings ||= {}
	  end
	end