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