# File gofer/messaging/policy.rb, line 44
  def initialize(producer, timeout)
    super(producer)
    @timeout = (timeout.is_a?(Array) ? timeout : [timeout])
    @queue = Gofer::Queue.new(getuuid(), false)
    @reader = Reader.new(@queue, nil, producer.url)
    @reader.start()
  end