Method: SolidQueue::LogSubscriber#register_process

Defined in:
lib/solid_queue/log_subscriber.rb

#register_process(event) ⇒ Object 



90
91
92
93
94
95
96
97
98
99
 
# File 'lib/solid_queue/log_subscriber.rb', line 90

def register_process(event)
  process_kind = event.payload[:kind]
  attributes = event.payload.slice(:pid, :hostname, :process_id, :name)

  if error = event.payload[:error]
    warn formatted_event(event, action: "Error registering #{process_kind}", **attributes.merge(error: formatted_error(error)))
  else
    debug formatted_event(event, action: "Register #{process_kind}", **attributes)
  end
end