deadLetter method

  1. @override
Future<void> deadLetter(
  1. Delivery delivery, {
  2. String? reason,
  3. Map<String, Object?>? meta,
})
override

Sends the delivery to the dead letter queue.

reason provides the reason for dead lettering, and meta additional data.

Implementation

@override
Future<void> deadLetter(
  Delivery delivery, {
  String? reason,
  Map<String, Object?>? meta,
}) async {
  if (delivery.route.isBroadcast) {
    _broadcastHub.ack(delivery.receipt);
    return;
  }
  _state(
    delivery.envelope.queue,
  ).deadLetter(delivery.receipt, reason: reason, meta: meta);
}