class RailwayIpc::ProcessIncomingMessage::NormalMessageJob
Attributes
handler[R]
incoming_message[R]
status[R]
Public Class Methods
new(incoming_message, handler)
click to toggle source
# File lib/railway_ipc/consumer/process_incoming_message.rb, line 50 def initialize(incoming_message, handler) @incoming_message = incoming_message @handler = handler @status = 'not_processed' end
Public Instance Methods
run()
click to toggle source
# File lib/railway_ipc/consumer/process_incoming_message.rb, line 56 def run result = handler.handle(incoming_message.decoded) @status = result.success? ? RailwayIpc::ConsumedMessage::STATUS_SUCCESS : RailwayIpc::ConsumedMessage::STATUS_FAILED_TO_PROCESS end