class RabbitmqClient::JsonLogSubscriber

Manage RabbitmqClient plain text logs

Public Instance Methods

confirming_message(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 43
def confirming_message(event)
  debug({ action: 'confirming_message',
          message: 'Confirming a message' }.merge(
            process_payload(event.payload)
          ))
end
created_exhange(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 63
def created_exhange(event)
  debug(action: 'created_exhange',
        message: 'Exhange is created successfuly',
        exchange_name: event.payload.fetch(:name))
end
exhange_not_found(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 57
def exhange_not_found(event)
  error(action: 'exhange_not_found',
        message: 'Exhange Not Found',
        exchange_name: event.payload.fetch(:name))
end
message_confirmed(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 50
def message_confirmed(event)
  debug({ action: 'message_confirmed',
          message: 'Confirmed a message' }.merge(
            process_payload(event.payload)
          ))
end
network_error(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 14
def network_error(event)
  payload = event.payload
  error({ action: 'network_error',
          message: 'Failed to publish a message',
          error_message: payload.fetch(:error).message }.merge(
            process_payload(payload)
          ))
end
overriding_configs(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 23
def overriding_configs(event)
  debug(action: 'overriding_configs',
        message: 'Overriding publisher configs',
        publisher_configs: event.payload)
end
published_message(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 36
def published_message(event)
  info({ action: 'published_message',
         message: 'Published a message' }.merge(
           process_payload(event.payload)
         ))
end
publisher_created(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 8
def publisher_created(event)
  debug(action: 'publisher_created',
        message: 'The RabbitmqClient publisher is created',
        publisher_configs: event.payload)
end
publishing_message(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 29
def publishing_message(event)
  debug({ action: 'publishing_message',
          message: 'Publishing a new message' }.merge(
            process_payload(event.payload)
          ))
end

Private Instance Methods

process_payload(payload) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 83
def process_payload(payload)
  {
    exchange_name: payload.fetch(:exchange, 'undefined'),
    message_id: payload.fetch(:message_id, 'undefined')
  }
end
rabbitmq_client_event(event) click to toggle source
# File lib/rabbitmq_client/json_log_subscriber.rb, line 79
def rabbitmq_client_event(event)
  { source: 'rabbitmq_client' }.merge(event)
end