Class: RailwayIpc::ProcessIncomingMessage
- Inherits:
-
Object
- Object
- RailwayIpc::ProcessIncomingMessage
- Defined in:
- lib/railway_ipc/consumer/process_incoming_message.rb
Defined Under Namespace
Classes: IgnoredMessageJob, NormalMessageJob, UnknownMessageJob
Instance Attribute Summary collapse
-
#consumer ⇒ Object
readonly
Returns the value of attribute consumer.
-
#incoming_message ⇒ Object
readonly
Returns the value of attribute incoming_message.
-
#logger ⇒ Object
readonly
Returns the value of attribute logger.
Class Method Summary collapse
Instance Method Summary collapse
- #call ⇒ Object
-
#initialize(consumer, incoming_message, logger: RailwayIpc.logger) ⇒ ProcessIncomingMessage
constructor
A new instance of ProcessIncomingMessage.
Constructor Details
#initialize(consumer, incoming_message, logger: RailwayIpc.logger) ⇒ ProcessIncomingMessage
Returns a new instance of ProcessIncomingMessage.
68 69 70 71 72 |
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 68 def initialize(consumer, , logger: RailwayIpc.logger) @consumer = consumer @incoming_message = @logger = logger end |
Instance Attribute Details
#consumer ⇒ Object (readonly)
Returns the value of attribute consumer.
62 63 64 |
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 62 def consumer @consumer end |
#incoming_message ⇒ Object (readonly)
Returns the value of attribute incoming_message.
62 63 64 |
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 62 def @incoming_message end |
#logger ⇒ Object (readonly)
Returns the value of attribute logger.
62 63 64 |
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 62 def logger @logger end |
Class Method Details
.call(consumer, incoming_message) ⇒ Object
64 65 66 |
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 64 def self.call(consumer, ) new(consumer, ).call end |
Instance Method Details
#call ⇒ Object
74 75 76 77 78 79 80 |
# File 'lib/railway_ipc/consumer/process_incoming_message.rb', line 74 def call unless .valid? = return if .processed? .update_with_lock() end |