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