| #!/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() |