Contents

require 'rubygems'
require 'jsparrow'

JSparrow::Connection.configure do
  use_jms_client_jar '/opt/openjms/lib/openjms-0.7.7-beta-1.jar'

  use_jndi_properties :initial_context_factory => 'org.exolab.jms.jndi.InitialContextFactory',
                      :provider_url            => 'tcp://localhost:3035'
                    # :security_principal      => 'user',
                    # :security_credentials    => 'password'

  enable_connection_factories :topic_connection_factory => 'ConnectionFactory'
  
  enable_topics :test_topic => 'TestTopic'
end

jms_client = JSparrow::Connection.new_client
jms_client.start

jms_client.topic_sender(:test_topic).send_text_message('jsparrow rocks!') do |msg|
  msg.set_string_property('recipient', 'jsparrow-example')
end

jms_client.topic_receiver(:test_topic).receive_message(
    :timeout  => 5000,
    :selector => "recipient = 'jsparrow-example'"
  ) do |msg|
  
  puts "is text message? #{msg.is_text_message?}"    # is text message? true
  puts "message: #{msg.text}"                        # message: jsparrow rocks!
end

jms_client.stop

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
jsparrow-1.1.3	sample/sample_topic.rb