Module: Announce::Testing

Defined in:
lib/announce/testing.rb

Instance Method Summary collapse

Instance Method Details

#broker_configured? ⇒ Boolean

Returns:

  • (Boolean) 


29
30
31
 
# File 'lib/announce/testing.rb', line 29

def broker_configured?
  Announce::Adapters::TestAdapter::BrokerManager.configured?
end

#clear_messages ⇒ Object 



13
14
15
 
# File 'lib/announce/testing.rb', line 13

def clear_messages
  published_messages.clear
end

#clear_subscriptions ⇒ Object 



25
26
27
 
# File 'lib/announce/testing.rb', line 25

def clear_subscriptions
  subscriptions.clear
end

#last_message ⇒ Object 



9
10
11
 
# File 'lib/announce/testing.rb', line 9

def last_message
  published_messages.last
end

#last_subscription ⇒ Object 



21
22
23
 
# File 'lib/announce/testing.rb', line 21

def last_subscription
  subscriptions.last
end

#published_messages ⇒ Object 



5
6
7
 
# File 'lib/announce/testing.rb', line 5

def published_messages
  Announce::Adapters::TestAdapter::Topic.published_messages
end

#reset_announce ⇒ Object 



37
38
39
40
41
42
43
 
# File 'lib/announce/testing.rb', line 37

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 ⇒ Object 



33
34
35
 
# File 'lib/announce/testing.rb', line 33

def reset_broker_config
  Announce::Adapters::TestAdapter::BrokerManager.reset
end

#subscriptions ⇒ Object 



17
18
19
 
# File 'lib/announce/testing.rb', line 17

def subscriptions
  Announce::Adapters::TestAdapter::Subscriber.subscriptions
end