require 'rubygems'
require 'spec'

require File.dirname(File.expand_path(__FILE__)) + '/../lib/jsparrow.rb'

#
# Helper methods for specs.
#
module JSparrowHelperMethods

  def configure_connection
    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', 
                                  :topic_connection_factory => 'ConnectionFactory'
      
      enable_queues :test_queue => 'TestQueue'
      
      enable_topics :test_topic => 'TestTopic'
    end
  end

  def new_jms_client
    configure_connection
    
    new_jsparrow_client
  end
  
  def new_named_jms_listener
    configure_connection
    
    new_jsparrow_listener :as => JSparrowHelperClasses::TestQueueListener
  end
  
  def new_anonymous_jms_listener
    listener = new_jsparrow_listener(
        :listen_to => { :queue => :test_queue },
        :receive_only_in_criteria => { :selector => "recipient = 'jsparrow-spec' and to_listener = 'anonymous'" }
      ) do |received_message|
        
      received_messages << received_message
    end
    
    def listener.received_messages
      @received_messages ||= []
    end
    
    listener
  end
  
  def send_message_to_listener(listener_name)
    @jms_client = new_jms_client
    @jms_client.start
    
    my_text = "Mensagem de texto enviada da spec para o listener #{listener_name}"
    
    @jms_client.queue_sender(:test_queue).send_text_message(my_text) do |msg|
      msg.add_criteria_to_reception('recipient',   'jsparrow-spec')
      msg.add_criteria_to_reception('to_listener', listener_name)
    end

    @jms_client.stop
  end
end

module JSparrowHelperClasses
  #
  # Listener for test against "TestQueue" queue
  #
  class TestQueueListener < JSparrow::Interactors::Listener
    listen_to :queue => :test_queue
  
    receive_only_in_criteria :selector => "recipient = 'jsparrow-spec' and to_listener = 'TestQueueListener'"
  
    attr_reader :received_messages
  
    def initialize(connection)
      super(connection)
    
      @received_messages = []
    end
  
    def on_receive_message(received_message)
      @received_messages << received_message
    end
  end
end

#
# Some steroids for Spec::Example::ExampleGroup.
#
class Spec::Example::ExampleGroup
  include JSparrowHelperMethods
end