class RabbitmqClient::PlainLogSubscriber

Manage RabbitmqClient plain text logs

Public Instance Methods

confirming_message(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 43
def confirming_message(event)
  msg = 'Start>> confirming a message ' \
        "(message_id: #{event.payload.fetch(:message_id, 'undefined')})"
  debug(msg)
end
created_exhange(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 60
def created_exhange(event)
  debug("The #{event.payload.fetch(:name)} exchange is created successfuly")
end
exhange_not_found(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 56
def exhange_not_found(event)
  error("The Exchange '#{event.payload.fetch(:name)}' cannot be found")
end
message_confirmed(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 49
def message_confirmed(event)
  msg_id = event.payload.fetch(:message_id, 'undefined')
  msg = '<<DONE confirmed a message ' \
        "(message_id: #{msg_id}) Successfuly"
  debug(msg)
end
network_error(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 14
def network_error(event)
  payload = event.payload
  msg = "Failed to publish a message (#{payload.fetch(:error).message}) " \
        "to exchange (#{payload.dig(:options, :exchange_name)})"
  error(msg)
end
overriding_configs(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 21
def overriding_configs(event)
  msg = 'Overriding the follwing configs for ' \
        "the created publisher #{event.payload.inspect}"
  debug(msg)
end
published_message(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 35
def published_message(event)
  payload = event.payload
  msg = '<<DONE Published a message to ' \
       "the exchange (#{payload.fetch(:exchange, 'undefined')}) " \
       "with message_id: #{payload.fetch(:message_id, 'undefined')}"
  info(msg)
end
publisher_created(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 8
def publisher_created(event)
  msg = 'The RabbitmqClient publisher is created ' \
        "with the follwong configs #{event.payload.inspect}"
  debug(msg)
end
publishing_message(event) click to toggle source
# File lib/rabbitmq_client/plain_log_subscriber.rb, line 27
def publishing_message(event)
  payload = event.payload
  msg = 'Start>> Publishing a new message ' \
        "(message_id: #{payload.fetch(:message_id, 'undefined')} ) " \
        "to the exchange (#{payload.fetch(:exchange, 'undefined')})"
  debug(msg)
end