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