Module: Messaging::Kafka::MessageLogger

Defined in:
lib/messaging/kafka/message_logger.rb

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



30
31
32
 
# File 'lib/messaging/kafka/message_logger.rb', line 30

def logger
  @logger ||= Logger.new(STDOUT)
end

.message_buffer_flushed_on_shutdown ⇒ Object 



26
27
28
 
# File 'lib/messaging/kafka/message_logger.rb', line 26

def message_buffer_flushed_on_shutdown
  log_info("Published any pending messages before shutdown.")
end

.message_processed(payload, metadata) ⇒ Object 



14
15
16
 
# File 'lib/messaging/kafka/message_logger.rb', line 14

def message_processed(payload, metadata)
  log_info("Message Processed. #{message_processed_or_received_string(payload, metadata)}")
end

.message_publish_failed(message, exception) ⇒ Object 



18
19
20
 
# File 'lib/messaging/kafka/message_logger.rb', line 18

def message_publish_failed(message, exception)
  log_error("Message Publish Error. Topic: #{message.topic}, Body: #{message.body_json}, Exception Class: #{exception.class} Exception: #{exception}")
end

.message_publish_list_failed(messages, exception) ⇒ Object 



22
23
24
 
# File 'lib/messaging/kafka/message_logger.rb', line 22

def message_publish_list_failed(messages, exception)
  log_error("Message Publish List Error. Messages: #{messages}, Exception Class: #{exception.class}, Exception: #{exception}")
end

.message_published(topic, payload) ⇒ Object 



6
7
8
 
# File 'lib/messaging/kafka/message_logger.rb', line 6

def message_published(topic, payload)
  log_info("Message Published. Topic: #{topic}, Payload: #{payload}")
end

.message_received(payload, metadata) ⇒ Object 



10
11
12
 
# File 'lib/messaging/kafka/message_logger.rb', line 10

def message_received(payload, metadata)
  log_info("Message Received. #{message_processed_or_received_string(payload, metadata)}")
end