def initialize(payload, message, options = {})
options = {:base64 => false,
:agent => nil,
:headers => {},
:type => :message,
:request => nil,
:filter => Util.empty_filter,
:options => {},
:ttl => 60,
:expected_msgid => nil,
:requestid => nil,
:collective => nil}.merge(options)
@payload = payload
@message = message
@requestid = options[:requestid]
@discovered_hosts = nil
@reply_to = nil
@type = options[:type]
@headers = options[:headers]
@base64 = options[:base64]
@filter = options[:filter]
@expected_msgid = options[:expected_msgid]
@options = options[:options]
@ttl = @options[:ttl] || Config.instance.ttl
@msgtime = 0
@validated = false
if options[:request]
@request = options[:request]
@agent = request.agent
@collective = request.collective
@type = :reply
else
@agent = options[:agent]
@collective = options[:collective]
end
base64_decode!
end