require 'qpid_proton'
require 'optparse'
class HelloWorld < Qpid::Proton::MessagingHandler
def initialize(url, address)
super()
@url, @address = url, address
end
def on_container_start(container)
conn = container.connect(@url)
conn.open_sender(@address)
conn.open_receiver(@address)
end
def on_sendable(sender)
sender.send(Qpid::Proton::Message.new("Hello world!"))
sender.close
end
def on_message(delivery, message)
puts message.body
delivery.connection.close
end
def on_transport_error(transport)
raise "Connection error: #{transport.condition}"
end
end
if ARGV.size != 2
STDERR.puts "Usage: #{__FILE__} URL ADDRESS
Connect to URL, send a message to ADDRESS and receive it back"
return 1
end
url, address = ARGV
Qpid::Proton::Container.new(HelloWorld.new(url, address)).run
Apache Qpid, Messaging built on AMQP; Copyright © 2015 The Apache Software Foundation; Licensed under the Apache License, Version 2.0; Apache Qpid, Qpid, Qpid Proton, Proton, Apache, the Apache feather logo, and the Apache Qpid project logo are trademarks of The Apache Software Foundation; All other marks mentioned may be trademarks or registered trademarks of their respective owners