Sha256: 206076a5a8230e2beedb25a846a891476be46ab32d35dfb78ba8620d1eb4f562

Contents?: true

Size: 886 Bytes

Versions: 8

Compression:

Stored size: 886 Bytes

Contents

# Allow examples to be run in-place without requiring a gem install
$LOAD_PATH.unshift File.dirname(__FILE__) + '/../../lib'

require 'rubygems'
require 'erb'
require 'modern_times'
require 'yaml'

if ARGV.size < 2
  $stderr.puts "Usage: {$0} <message> <id>"
end

#ModernTimes::JMS::Publisher.setup_dummy_publishing([])
#ModernTimes::JMS::Consumer.setup_dummy_receiving

config = YAML.load(ERB.new(File.read(File.join(File.dirname(__FILE__), '..', 'jms.yml'))).result(binding))
ModernTimes::JMS::Connection.init(config)
publisher = ModernTimes::JMS::Publisher.new(:queue_name => 'Foo', :marshal => :string)
consumer = ModernTimes::JMS::Consumer.new(:queue_name => 'Foo', :marshal => :string)

publisher.publish(ARGV[0], :jms_correlation_id => ARGV[1])
msg = consumer.receive(:jms_correlation_id => ARGV[1], :timeout => 30000)
#msg = consumer.receive(:timeout => 1000)
puts "msg=#{msg}"

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
modern_times-0.3.3 examples/consumer/consumer.rb
modern_times-0.3.2 examples/consumer/consumer.rb
modern_times-0.3.1 examples/consumer/consumer.rb
modern_times-0.3.0 examples/consumer/consumer.rb
modern_times-0.2.11 examples/consumer/consumer.rb
modern_times-0.2.10 examples/consumer/consumer.rb
modern_times-0.2.8 examples/consumer/consumer.rb
modern_times-0.2.7 examples/consumer/consumer.rb