require 'qpid_proton'
require 'optparse'
class DirectSend < Qpid::Proton::MessagingHandler
def initialize(url, address, expected)
super()
@url = url
@address = address
@sent = 0
@confirmed = 0
@expected = expected
end
class ListenOnce < Qpid::Proton::Listener::Handler
def on_open(l) STDOUT.puts "Listening on #{l.port}\n"; STDOUT.flush; end
def on_accept(l) l.close; end
end
def on_container_start(container)
container.listen(@url, ListenOnce.new)
end
def on_sendable(sender)
while sender.credit > 0 && @sent < @expected
msg = Qpid::Proton::Message.new("sequence #{@sent}", { :id => @sent } )
sender.send(msg)
@sent = @sent + 1
end
end
def on_tracker_accept(tracker)
@confirmed = @confirmed + 1
if @confirmed == @expected
puts "All #{@expected} messages confirmed!"
tracker.connection.close
end
end
end
unless (2..3).include? ARGV.size
STDERR.puts "Usage: #{__FILE__} URL ADDRESS [COUNT]
Listen on URL and send COUNT messages to ADDRESS"
return 1
end
url, address, count = ARGV
count = Integer(count || 10)
Qpid::Proton::Container.new(DirectSend.new(url, address, count)).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