ack method

  1. @override
Future<void> ack(
  1. Delivery delivery
)
override

Acknowledges a delivery, removing it from in-flight tracking.

Implementation

@override
/// Acknowledges a delivery, removing it from in-flight tracking.
Future<void> ack(Delivery delivery) async {
  if (delivery.route.isBroadcast) {
    _broadcastHub.ack(delivery.receipt);
    return;
  }
  _state(delivery.envelope.queue).ack(delivery.receipt);
}