Sha256: 16d6200d55f67bc9ecb3762f5521d4ad180489d39c2e7f47c07723e9086e9737
Contents?: true
Size: 846 Bytes
Versions: 27
Compression:
Stored size: 846 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Consumers
# Feature that allows us to use responders flow in consumer
module Responders
# Responds with given data using given responder. This allows us to have a similar way of
# defining flows like synchronous protocols
# @param data Anything we want to pass to responder based on which we want to trigger further
# Kafka responding
def respond_with(*data)
Karafka.monitor.instrument(
'consumers.responders.respond_with',
caller: self,
data: data
) do
# @note we build a new instance of responder each time, as a long-running (persisted)
# consumers can respond multiple times during the life-cycle
topic.responder.new.call(*data)
end
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems