Class: Rdkafka::Producer::DeliveryHandle

Inherits:
AbstractHandle show all
Defined in:
lib/rdkafka/producer/delivery_handle.rb

Overview

Handle to wait for a delivery report which is returned when producing a message.

Constant Summary

Constants inherited from AbstractHandle

AbstractHandle::REGISTRY

Instance Method Summary collapse

Methods inherited from AbstractHandle

#pending?, #raise_error, register, remove, #wait

Instance Method Details

#create_resultDeliveryReport

Returns a report on the delivery of the message.

Returns:


17
18
19
# File 'lib/rdkafka/producer/delivery_handle.rb', line 17

def create_result
  DeliveryReport.new(self[:partition], self[:offset])
end

#operation_nameString

Returns the name of the operation (e.g. "delivery").

Returns:

  • (String)

    the name of the operation (e.g. "delivery")


12
13
14
# File 'lib/rdkafka/producer/delivery_handle.rb', line 12

def operation_name
  "delivery"
end