Consumer.throwException

Throws an exception in the consumer task. This is used to pass the connection exceptions to the user.

class Consumer
void
throwException
(
Exception ex
)

Meta