Class: RailwayIpc::ProcessIncomingMessage::IgnoredMessageJob

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) ⇒ IgnoredMessageJob

Returns a new instance of IgnoredMessageJob.



29
30
31
32
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 29

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.



27
28
29
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 27

def incoming_message
  @incoming_message
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



27
28
29
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 27

def logger
  @logger
end

Instance Method Details

#run ⇒ Object 



38
39
40
41
42
43
44
 
# 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 ⇒ Object 



34
35
36
 
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 34

def status
  'ignored'
end