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.



12
13
14

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

def initialize(cb)
  @cb = cb
end

Instance Method Details

#onCompletion(metadata, exception) ⇒ `Object`



16
17
18

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

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