notifyConsumingFailed method

void notifyConsumingFailed(
  1. String endpoint,
  2. Exception error
)

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