Class: RailwayIpc::ProcessIncomingMessage::UnknownMessageJob

Inherits:
Object
  • Object
show all
Defined in:
lib/railway_ipc/consumer/process_incoming_message.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(incoming_message, logger) ⇒ UnknownMessageJob

Returns a new instance of UnknownMessageJob.



8
9
10
11
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 8

def initialize(incoming_message, logger)
  @incoming_message = incoming_message
  @logger = logger
end

Instance Attribute Details

#incoming_message ⇒ Object (readonly)

Returns the value of attribute incoming_message.



6
7
8
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 6

def incoming_message
  @incoming_message
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



6
7
8
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 6

def logger
  @logger
end

Instance Method Details

#run ⇒ Object 



17
18
19
20
21
22
23
 
# 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 ⇒ Object 



13
14
15
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 13

def status
  'unknown_message_type'
end