lib/mimi/messaging/kafka/reply_listener.rb
# Register a new request_id to listen for.
#
# Whenever the message with given request_id will be received,
# it will be dispatched to a returned Queue.
#
# @param request_id [String]
# @return [Queue] a new Queue object registered for this request_id
#
Register a new request_id to listen for.
Whenever the message with given request_id will be received,
it will be dispatched to a returned Queue.
Register a new request_id to listen for . Whenever the message with given request_id will be received it will be dispatched to a returned Queue .
def register_request_id(request_id)
          queue = Queue.new
          @mutex.synchronize do
            queue = @queues[request_id] ||= queue
          end
          queue
        end
def register_request_id ( request_id ) queue = Queue . new @mutex . synchronize do queue = @queues [ request_id ] ||= queue end queue end
Register a new request_id to listen for.
Register a new request_id to listen for .
a new Queue object registered for this request_id
a new Queue object registered for this request_id
Queue
request_id
<not_specific>
<not_specific>
None