Class: WaterDrop::Errors::ProduceManyError

Inherits:

ProduceError

• Object
• WaterDrop::Errors::ProduceManyError

Defined in:

lib/waterdrop/errors.rb

Overview

Raised when during messages producing something bad happened inline

Instance Attribute Summary

• #dispatched ⇒ Object readonly

  Returns the value of attribute dispatched.

Instance Method Summary

• #initialize(dispatched) ⇒ ProduceManyError constructor

  A new instance of ProduceManyError.

Constructor Details

#initialize(dispatched) ⇒ ProduceManyError

Returns a new instance of ProduceManyError.

Parameters:

• dispatched (Array<Rdkafka::Producer::DeliveryHandle>) —

  handlers of the messages that we’ve dispatched

# File 'lib/waterdrop/errors.rb', line 41

def initialize(dispatched)
  super()
  @dispatched = dispatched
end

Instance Attribute Details

#dispatched ⇒ Object (readonly)

Returns the value of attribute dispatched.

# File 'lib/waterdrop/errors.rb', line 37

def dispatched
  @dispatched
end