class BPS::Publisher::Kafka::Topic
Public Class Methods
new(producer, topic)
click to toggle source
Calls superclass method
# File lib/bps/publisher/kafka.rb, line 7 def initialize(producer, topic) super() @producer = producer @topic = topic end
Public Instance Methods
flush(**)
click to toggle source
# File lib/bps/publisher/kafka.rb, line 19 def flush(**) @producer.deliver_messages end
publish(message, **opts)
click to toggle source
# File lib/bps/publisher/kafka.rb, line 14 def publish(message, **opts) @producer.produce(message, **opts, topic: @topic) after_publish end
Protected Instance Methods
after_publish()
click to toggle source
# File lib/bps/publisher/kafka.rb, line 25 def after_publish @producer.deliver_messages nil end