Sha256: 38c2cec131df728eedc30ae6aef717246af42bab23f469e05df36d2421063eb0
Contents?: true
Size: 1.07 KB
Versions: 9
Compression:
Stored size: 1.07 KB
Contents
# frozen_string_literal: true
module WaterDrop
module Clients
# A dummy client that is supposed to be used instead of Rdkafka::Producer in case we don't
# want to dispatch anything to Kafka.
#
# It does not store anything and just ignores messages.
class Dummy
# @param _producer [WaterDrop::Producer]
# @return [Dummy] dummy instance
def initialize(_producer)
@counter = -1
end
# Dummy method for returning the delivery report
# @param _args [Object] anything that the delivery handle accepts
# @return [::Rdkafka::Producer::DeliveryReport]
def wait(*_args)
::Rdkafka::Producer::DeliveryReport.new(0, @counter += 1)
end
# @param _args [Object] anything really, this dummy is suppose to support anything
def respond_to_missing?(*_args)
true
end
# @param _args [Object] anything really, this dummy is suppose to support anything
# @return [self] returns self for chaining cases
def method_missing(*_args)
self || super
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems