Exception: Rdkafka::ClosedConsumerError

Inherits:
BaseError
  • Object
show all
Defined in:
lib/rdkafka/error.rb

Overview

Error class for public consumer method calls on a closed consumer.

Instance Method Summary collapse

Constructor Details

#initialize(method) ⇒ ClosedConsumerError

Returns a new instance of ClosedConsumerError.

Parameters:

  • method (Symbol)

    the method that was called



97
98
99
# File 'lib/rdkafka/error.rb', line 97

def initialize(method)
  super("Illegal call to #{method} on a closed consumer")
end