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 :queue_connection_factory => 'ConnectionFactory'
  
  enable_queues :test_queue => 'TestQueue'
end

jms_client = new_jsparrow_client
jms_client.start

jms_client.queue_sender(:test_queue).send_text_message('jsparrow rocks!') do |msg|
  msg.add_criteria_to_reception('recipient', 'jsparrow-example')
end

jms_client.queue_receiver(:test_queue).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