class RailwayIpc::ProcessIncomingMessage::IgnoredMessageJob

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 29
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 38
def run
  logger.warn(
    "Ignoring message, no registered handler for '#{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 34
def status
  'ignored'
end