blob: c6865afd9ea3054ed38174fded3c112caa2bc75c [file] [log] [blame]
#!/usr/bin/env ruby
require 'qpid_proton.rb'
messenger = Qpid::Proton::Messenger.new()
messenger.outgoing_window = 10
message = Qpid::Proton::Message.new()
address = ARGV[0]
if not address then
address = "0.0.0.0"
end
message.address = address
message.properties = {"binding" => "ruby",
"version" => "#{RUBY_VERSION} #{RUBY_PLATFORM}"}
message.body = "Hello World!"
messenger.start()
tracker = messenger.put(message)
print "Put: #{message}\n"
messenger.send()
print "Status: ", messenger.status(tracker), "\n"
messenger.stop()