# 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