# File gofer/messaging/producer.rb, line 27 def send(destination, body={}, ttl=nil) sn = getuuid() ssn = self.session() envelope = { :sn=>sn, :version=>Gofer::VERSION, :origin=>self.id() } envelope.update(body) json = JSON.pretty_generate(envelope) address = destination.to_s() dp = ssn.delivery_properties(:routing_key=>address, :ttl=>ttl) mp = ssn.message_properties(:content_type=>"text/plain") msg = Qpid::Message.new(dp, mp, json) ssn.message_transfer(:message=>msg) puts "#{self.id} sent (#{address})\n#{envelope}" return sn end