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