#!/usr/bin/env ruby | |
require 'qpid_proton.rb' | |
messenger = Qpid::Proton::Messenger.new() | |
messenger.incoming_window = 1 | |
message = Qpid::Proton::Message.new() | |
address = ARGV[0] | |
if not address then | |
address = "~0.0.0.0" | |
end | |
messenger.subscribe(address) | |
messenger.start() | |
while (true) do | |
messenger.receive() | |
messenger.get(message) | |
print "Got: #{message}\n" | |
messenger.accept() | |
end | |
messenger.stop() |