Contents

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

module Propono
  class SnsToSqsTest < IntegrationTest
    def test_the_message_gets_there
      topic = "test-topic"
      text = "This is my message"

      thread = Thread.new do
        Propono.listen_to_queue(topic) do |message|
          assert_equal text, message
          break
        end
      end
      Propono.publish(topic, text)
      flunk unless wait_for_thread(thread)
    ensure
      thread.terminate
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
propono-0.6.1	test/integration/sns_to_sqs_test.rb
propono-0.6.0	test/integration/sns_to_sqs_test.rb