Class: Kafka::KafkaProducer::RubyCallback

Inherits:

Object

Object
Kafka::KafkaProducer::RubyCallback

Includes:: Callback

Defined in:: lib/jruby-kafka/kafka-producer.rb

Instance Method Summary collapse

#initialize(cb) ⇒ RubyCallback constructor

A new instance of RubyCallback.
#onCompletion(metadata, exception) ⇒ Object

Constructor Details

#initialize(cb) ⇒ `RubyCallback`

Returns a new instance of RubyCallback.



18
19
20

# File 'lib/jruby-kafka/kafka-producer.rb', line 18

def initialize(cb)
  @cb = cb
end

Instance Method Details

#onCompletion(metadata, exception) ⇒ `Object`



22
23
24

# File 'lib/jruby-kafka/kafka-producer.rb', line 22

def onCompletion(metadata, exception)
  @cb.call(metadata, exception)
end