Class: LogMessageHandler

Inherits:
GorgService::Consumer::MessageHandler::Base show all
Defined in:
lib/gorg_service/rspec/log_message_handler.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from GorgService::Consumer::MessageHandler::Base

handle_error, listen_to, #message, #process, #raise_hardfail, raise_hardfail, raise_softfail, #raise_softfail, reply_to, #reply_with, reset_listen_to!, #validate

Constructor Details

#initialize(msg) ⇒ LogMessageHandler

Returns a new instance of LogMessageHandler.



2
3
4
5
 
# File 'lib/gorg_service/rspec/log_message_handler.rb', line 2

def initialize(msg)
  GorgService.logger.debug "Message received in LogMessageHandler"
  self.class.messages<<msg
end

Class Method Details

.has_received_a_message_with_routing_key?(routing_key) ⇒ Boolean

Returns:

  • (Boolean) 


23
24
25
 
# File 'lib/gorg_service/rspec/log_message_handler.rb', line 23

def self.has_received_a_message_with_routing_key?(routing_key)
  messages.any?{|m| m.routing_key==routing_key}
end

.has_received_error?(type) ⇒ Boolean

Returns:

  • (Boolean) 


11
12
13
 
# File 'lib/gorg_service/rspec/log_message_handler.rb', line 11

def self.has_received_error?(type)
  messages.any?{|m| m.errors.any?{|x| x.type==type}}
end

.has_received_hardfail? ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
 
# File 'lib/gorg_service/rspec/log_message_handler.rb', line 15

def self.has_received_hardfail?
  self.has_received_error?("harderror")
end

.messages ⇒ Object 



7
8
9
 
# File 'lib/gorg_service/rspec/log_message_handler.rb', line 7

def self.messages
  @@messages||=[]
end

.reset ⇒ Object 



27
28
29
 
# File 'lib/gorg_service/rspec/log_message_handler.rb', line 27

def self.reset
  @@messages=nil
end