module Announce::Testing

Public Instance Methods

broker_configured?() click to toggle source
# File lib/announce/testing.rb, line 31
def broker_configured?
  Announce::Adapters::TestAdapter::BrokerManager.configured?
end
clear_messages() click to toggle source
# File lib/announce/testing.rb, line 15
def clear_messages
  published_messages.clear
end
clear_subscriptions() click to toggle source
# File lib/announce/testing.rb, line 27
def clear_subscriptions
  subscriptions.clear
end
last_message() click to toggle source
# File lib/announce/testing.rb, line 11
def last_message
  published_messages.last
end
last_subscription() click to toggle source
# File lib/announce/testing.rb, line 23
def last_subscription
  subscriptions.last
end
published_messages() click to toggle source
# File lib/announce/testing.rb, line 7
def published_messages
  Announce::Adapters::TestAdapter::Topic.published_messages
end
reset_announce() click to toggle source
# File lib/announce/testing.rb, line 39
def reset_announce
  Announce.logger = Logger.new('/dev/null')
  Announce.options[:adapter] = 'test'
  Announce.options[:queue_name_prefix] = 'test'
  Announce.options[:app_name] = 'app'
  clear_messages
end
reset_broker_config() click to toggle source
# File lib/announce/testing.rb, line 35
def reset_broker_config
  Announce::Adapters::TestAdapter::BrokerManager.reset
end
subscriptions() click to toggle source
# File lib/announce/testing.rb, line 19
def subscriptions
  Announce::Adapters::TestAdapter::Subscriber.subscriptions
end