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, message) ⇒ ProduceManyError constructor

  A new instance of ProduceManyError.

Constructor Details

#initialize(dispatched, message) ⇒ ProduceManyError

Returns a new instance of ProduceManyError.

Parameters:

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

  handlers of the messages that we’ve dispatched

• message (String) —

  error message

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

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

Instance Attribute Details

#dispatched ⇒ Object (readonly)

Returns the value of attribute dispatched.

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

def dispatched
  @dispatched
end