Module: Announce::Testing

Defined in:
lib/announce/testing.rb

Instance Method Summary collapse

Instance Method Details

#broker_configured? ⇒ Boolean

Returns:

  • (Boolean) 


31
32
33
 
# File 'lib/announce/testing.rb', line 31

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

#clear_messages ⇒ Object 



15
16
17
 
# File 'lib/announce/testing.rb', line 15

def clear_messages
  published_messages.clear
end

#clear_subscriptions ⇒ Object 



27
28
29
 
# File 'lib/announce/testing.rb', line 27

def clear_subscriptions
  subscriptions.clear
end

#last_message ⇒ Object 



11
12
13
 
# File 'lib/announce/testing.rb', line 11

def last_message
  published_messages.last
end

#last_subscription ⇒ Object 



23
24
25
 
# File 'lib/announce/testing.rb', line 23

def last_subscription
  subscriptions.last
end

#published_messages ⇒ Object 



7
8
9
 
# File 'lib/announce/testing.rb', line 7

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

#reset_announce ⇒ Object 



39
40
41
42
43
44
45
 
# 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 ⇒ Object 



35
36
37
 
# File 'lib/announce/testing.rb', line 35

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

#subscriptions ⇒ Object 



19
20
21
 
# File 'lib/announce/testing.rb', line 19

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