Contents

require File.expand_path('../test_helper', __FILE__)

module Larva
  class ListenerTest < Minitest::Test
    def test_listen_to_queue_is_called
      topic_name = "Foo"
      queue_suffix = "bar"
      Propono.expects(:listen_to_queue).with("#{topic_name}#{queue_suffix}")
      Larva::Listener.listen(topic_name, nil, queue_suffix)
    end

    def test_listener_logs_listening_message
      topic_name = "Foo"
      queue_suffix = "bar"

      message = "Starting to listen to queue #{topic_name}#{queue_suffix}"
      Propono.config.logger.expects(:info).with(message)
      Propono.stubs(:listen_to_queue)
      Larva::Listener.listen(topic_name, nil, queue_suffix)
    end

    def test_listener_changes_context
      context = {id: "34sdf"}
      Propono.config.logger.expects(:context_id=).with(context[:id])
      Propono.stubs(:listen_to_queue).yields(nil, context)
      Larva::Listener.listen("foobar", mock(process: nil), nil)
    end

    def test_listener_logs_message
      message = {foo: 'bar'}
      context = {id: "34sdf"}
      Propono.config.logger.stubs(:info)
      Propono.config.logger.expects(:info).with("Received message: #{message}")
      Propono.stubs(:listen_to_queue).yields(message, context)
      Larva::Listener.listen("foobar", mock(process: nil), nil)
    end

    def test_processor_is_called_with_message
      processor = mock
      message = {foo: 'bar'}
      processor.expects(:process).with(message)
      Propono.expects(:listen_to_queue).yields(message, {})
      Larva::Listener.listen("foobar", processor, "")
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
larva-0.4.1	test/listener_test.rb
larva-0.4.0	test/listener_test.rb
larva-0.3.0	test/listener_test.rb
larva-0.1.0	test/listener_test.rb