subscribeConsumingFailed method

void subscribeConsumingFailed(
  1. dynamic callback(
    1. String,
    2. Exception
    )
)

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);
}