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