Menu Search

client.rb

require 'qpid_proton'
require 'optparse'


$options  = {
  :verbose => false,
  :hostname => "0.0.0.0",
  :subject => "",
  :replyto => "~/replies"
}


OptionParser.new do |opts|
  opts.banner = "Usage: client [options] <addr> <subject>"

  opts.on("-r", "--reply-to", String, :REQUIRED,
          "Reply address") do |replyto|
    $options[:replyto] = replyto
  end

  opts.on("-v", "--verbose", :NONE,
          "Enable verbose output") do
    $options[:verbose] = true
  end

  opts.on("-h", "--help", :NONE,
          "Show this help message") do
    puts opts
    exit
  end

  begin
    ARGV << "-h" if ARGV.empty?
    opts.parse!(ARGV)
  rescue OptionParser::ParseError => error
    STDERR.puts error.message, "\n", opts
    exit 1
  end

  ($options[:address], $options[:subject]) = ARGV

  abort "No address specified" if $options[:hostname].nil?
  abort "No subject specified" if $options[:subject].nil?

end

def log(text)
  printf "#{Time.new}: #{text}\n" if $options[:verbose]
end

msgr = Qpid::Proton::Messenger.new
msgr.start

msg = Qpid::Proton::Message.new
msg.address = $options[:address]
msg.subject = $options[:subject]
msg.reply_to = $options[:replyto]

msgr.put(msg)
msgr.send

if $options[:replyto].start_with? "~/"
  msgr.receive(1)
  begin
    msgr.get(msg)
    puts "#{msg.address}, #{msg.subject}"
  rescue error
    puts error
  end
end

msgr.stop

Download this file