Class: WaterDrop::Errors::ProduceManyError

Inherits:
ProduceError
  • Object
show all
Defined in:
lib/waterdrop/errors.rb

Overview

Raised when during messages producing something bad happened inline

Instance Attribute Summary collapse

Instance Method Summary collapse

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



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

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

Instance Attribute Details

#dispatchedObject (readonly)

Returns the value of attribute dispatched.



49
50
51
# File 'lib/waterdrop/errors.rb', line 49

def dispatched
  @dispatched
end