require 'qpid_proton'
require 'optparse'
class DirectReceive < Qpid::Proton::MessagingHandler
def initialize(url, address, count)
super()
@url = url
@address = address
@expected = count
@received = 0
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_message(delivery, message)
if @expected.zero? || (@received < @expected)
puts "Received: #{message.body}"
@received = @received + 1
if @received == @expected
delivery.connection.close
end
end
end
end
unless (2..3).include? ARGV.size
STDERR.puts "Usage: #{__FILE__} URL ADDRESS [COUNT]
Listen on URL and receive COUNT messages from ADDRESS"
return 1
end
url, address, count = ARGV
count = Integer(count || 10)
Qpid::Proton::Container.new(DirectReceive.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