lib/mimi/messaging/kafka/reply_listener.rb
# Dispatch message received on a reply topic
#
# @param message [Kafka::FetchedMessage]
#
Dispatch message received on a reply topic
Dispatch message received on a reply topic
def dispatch_message(message)
          queue = nil
          @mutex.synchronize do
            request_id = message.headers["__request_id"]
            queue = @queues.delete(request_id)
          end
          queue&.push(message)
        end
def dispatch_message ( message ) queue = nil @mutex . synchronize do request_id = message . headers [ "__request_id" ] queue = @queues . delete ( request_id ) end queue &. push ( message ) end
Dispatch message received on a reply topic
Dispatch message received on a reply topic
message
<not_specific>
<not_specific>
None