notifyConsumingFailed method
PROTECTED: DO NOT USE UNLESS YOU ARE AN ActiveBrokerInterface.
Implementation
void notifyConsumingFailed(String endpoint, Exception error) {
for (final Function(String, Exception) callback
in _callbacksConsumingFailed) {
callback(endpoint, error);
}
}