class WaterDrop::Errors::ProduceManyError

Raised when during messages producing something bad happened inline

Attributes

dispatched[R]

Public Class Methods

new(dispatched, message) click to toggle source

@param dispatched [Array<Rdkafka::Producer::DeliveryHandle>] handlers of the

messages that we've dispatched

@param message [String] error message

Calls superclass method
# File lib/waterdrop/errors.rb, line 57
def initialize(dispatched, message)
  super(message)
  @dispatched = dispatched
end