class RailwayIpc::ProcessIncomingMessage::UnknownMessageJob

Attributes

incoming_message[R]
logger[R]

Public Class Methods

new(incoming_message, logger) click to toggle source
# File lib/railway_ipc/consumer/process_incoming_message.rb, line 8
def initialize(incoming_message, logger)
  @incoming_message = incoming_message
  @logger = logger
end

Public Instance Methods

run() click to toggle source
# File lib/railway_ipc/consumer/process_incoming_message.rb, line 17
def run
  logger.warn(
    "Ignoring unknown message of type '#{incoming_message.type}'",
    feature: 'railway_ipc_consumer',
    protobuf: { type: incoming_message.type, data: incoming_message.decoded }
  )
end
status() click to toggle source
# File lib/railway_ipc/consumer/process_incoming_message.rb, line 13
def status
  'unknown_message_type'
end