Class: WaterDrop::Errors::FlushFailureError

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

Overview

Raised when during messages flushing something bad happened

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(dispatched_messages) ⇒ FlushFailureError

Returns a new instance of FlushFailureError.

Parameters:

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

    handlers of the messages that we’ve dispatched



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

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

Instance Attribute Details

#dispatched_messages ⇒ Object (readonly)

Returns the value of attribute dispatched_messages.



34
35
36
 
# File 'lib/waterdrop/errors.rb', line 34

def dispatched_messages
  @dispatched_messages
end