def setup_queue(name, ids = nil)
      queue = {:name => name, :options => {:durable => true, :no_declare => @options[:secure]}}
      filter = [:from, :tags, :tries, :persistent]
      options = {:ack => true, Push => filter, Request => filter, Result => [:from], :brokers => ids}
      @client.subscribe(queue, nil, options) { |_, packet, header| handle_packet(name, packet, header) }
    end
def setup_queue(name, ids = nil)
      queue = {:name => name, :options => {:durable => true, :no_declare => @options[:secure]}}
      filter = [:from, :tags, :tries, :persistent]
      options = {:ack => true, Push => filter, Request => filter, Result => [:from], :brokers => ids}
      @client.subscribe(queue, nil, options) { |_, packet, header| handle_packet(name, packet, header) }
    end
Setup queue for this agent

 === Parameters
 name(String):: Queue name
 ids(Array):: Identity of brokers for which to subscribe, defaults to all usable

 === Return
 (Array):: Identity of brokers to which subscribe submitted (although may still fail)