subscribeConsumingFailed method
Subscribes to all errors during consuming from the endpoints. (ConsumingFailed-Event).
The first passed String is the endpoint and the second one is the exception during the connection process.
Implementation
void subscribeConsumingFailed(Function(String, Exception) callback) {
_callbacksConsumingFailed.add(callback);
}