module ActiveMessaging::TestHelper
Public Instance Methods
assert_has_messages(destination)
click to toggle source
# File lib/activemessaging/test_helper.rb, line 108 def assert_has_messages destination destination_name = ActiveMessaging::Gateway.find_destination(destination).value error_message = <<-EOF No messages for #{destination_name}. All messages: #{ActiveMessaging::Gateway.connection('default').all_messages.inspect} EOF destination = ActiveMessaging::Gateway.connection('default').find_destination destination_name assert !destination.nil? && !destination.messages.empty?, error_message end
assert_message(destination, body)
click to toggle source
# File lib/activemessaging/test_helper.rb, line 58 def assert_message destination, body destination = ActiveMessaging::Gateway.find_destination(destination).value error_message = <<-EOF Message for '#{destination}' with '#{body}' is not present. Messages: #{ActiveMessaging::Gateway.connection('default').all_messages.inspect} EOF assert ActiveMessaging::Gateway.connection.find_message(destination, body), error_message end
assert_no_message_with(destination, body)
click to toggle source
# File lib/activemessaging/test_helper.rb, line 68 def assert_no_message_with destination, body destination = ActiveMessaging::Gateway.find_destination(destination).value error_message = <<-EOF Message for '#{destination}' with '#{body}' is present. Messages: #{ActiveMessaging::Gateway.connection('default').all_messages.inspect} EOF assert_nil ActiveMessaging::Gateway.connection('default').find_message(destination, body), error_message end
assert_no_messages(destination)
click to toggle source
# File lib/activemessaging/test_helper.rb, line 78 def assert_no_messages destination destination = ActiveMessaging::Gateway.find_destination(destination).value error_message = <<-EOF Expected no messages. Messages: #{ActiveMessaging::Gateway.connection('default').all_messages.inspect} EOF assert_equal [], ActiveMessaging::Gateway.connection('default').all_messages, error_message end
assert_not_subscribed(destination)
click to toggle source
# File lib/activemessaging/test_helper.rb, line 98 def assert_not_subscribed destination destination = ActiveMessaging::Gateway.find_destination(destination).value error_message = <<-EOF Subscribed to #{destination}. Subscriptions: #{ActiveMessaging::Gateway.connection('default').subscriptions.inspect} EOF assert_nil ActiveMessaging::Gateway.connection('default').find_subscription(destination), error_message end
assert_subscribed(destination)
click to toggle source
# File lib/activemessaging/test_helper.rb, line 88 def assert_subscribed destination destination = ActiveMessaging::Gateway.find_destination(destination).value error_message = <<-EOF Not subscribed to #{destination}. Subscriptions: #{ActiveMessaging::Gateway.connection('default').subscriptions.inspect} EOF assert ActiveMessaging::Gateway.connection('default').find_subscription(destination), error_message end
mock_publish(destination, body, publisher=nil, headers={})
click to toggle source
# File lib/activemessaging/test_helper.rb, line 54 def mock_publish destination, body, publisher=nil, headers={} ActiveMessaging::Gateway.publish destination, body, publisher, headers end