lib/mimi/messaging/kafka/adapter.rb
# Returns the configured reply listener for this process
#
# @return [ReplyListener]
#
Returns the configured reply listener for this process
Returns the configured reply listener for this process
def reply_listener
          @reply_listener ||= begin
            reply_topic_name = "reply.#{SecureRandom.hex(8)}.#{Time.now.to_i}"
            Mimi::Messaging::Kafka::ReplyListener.new(self, reply_topic_name)
          end
        end
def reply_listener @reply_listener ||= begin reply_topic_name = "reply.#{SecureRandom.hex(8)}.#{Time.now.to_i}" Mimi :: Messaging :: Kafka :: ReplyListener . new ( self , reply_topic_name ) end end
Returns the configured reply listener for this process
Returns the configured reply listener for this process
None
ReplyListener