module ActiveMessaging::TestHelper

Public Instance Methods

assert_has_messages(destination) click to toggle source
# File lib/activemessaging/test_helper.rb, line 169
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 119
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 129
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 139
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 159
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 149
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

def setup_with_a13g

ActiveMessaging.reload_activemessaging

end

def teardown_with_a13g

ActiveMessaging::Gateway.reset

end

# File lib/activemessaging/test_helper.rb, line 115
def mock_publish destination, body, publisher=nil, headers={}
  ActiveMessaging::Gateway.publish destination, body, publisher, headers
end