Class: Rdkafka::Producer::DeliveryHandle

Inherits:

AbstractHandle

• Object
• FFI::Struct
• AbstractHandle
• Rdkafka::Producer::DeliveryHandle

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

• #create_result ⇒ DeliveryReport

  A report on the delivery of the message.

• #operation_name ⇒ String

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

Methods inherited from AbstractHandle

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

Instance Method Details

#create_result ⇒ DeliveryReport

Returns a report on the delivery of the message.

Returns:

• (DeliveryReport) —

  a report on the delivery of the message

# File 'lib/rdkafka/producer/delivery_handle.rb', line 20

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

#operation_name ⇒ String

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

Returns:

• (String) —

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

# File 'lib/rdkafka/producer/delivery_handle.rb', line 15

def operation_name
  "delivery"
end