java 60 lines · 9 steps

Dead-letter recovery with Spring AMQP

A Spring component consumes dead-lettered orders, tracks retry attempts, and either re-queues with backoff or escalates.

Explained by highlit

Spring Advanced dead-letter-queue retry exponential-backoff message-driven escalation

1@Component
2public class OrderRecoveryHandler {
3 
  private final RabbitTemplate rabbitTemplate;
  private final RecoveryAttemptRepository attempts;
  private final AlertService alertService;
7 
  public OrderRecoveryHandler(RabbitTemplate rabbitTemplate,
                              RecoveryAttemptRepository attempts,
                              AlertService alertService) {
      this.rabbitTemplate = rabbitTemplate;
      this.attempts = attempts;
      this.alertService = alertService;
  }
15 
  @RabbitListener(queues = "orders.payment.dlq")
  public void onPaymentFailure(FailedOrderMessage message,
                               @Header("x-death") List<Map<String, ?>> death) {
      recover(message, RecoverySource.PAYMENT, deathCount(death));
  }
21 
  @RabbitListener(queues = "orders.fulfillment.dlq")
  public void onFulfillmentFailure(FailedOrderMessage message,
                                   @Header("x-death") List<Map<String, ?>> death) {
      recover(message, RecoverySource.FULFILLMENT, deathCount(death));
  }
27 
  private void recover(FailedOrderMessage message, RecoverySource source, long deaths) {
      RecoveryAttempt attempt = attempts.findByOrderId(message.orderId())
              .orElseGet(() -> new RecoveryAttempt(message.orderId()));
      attempt.record(source, message.reason());
32 
      if (deaths >= 3 || attempt.hasFailedIn(RecoverySource.PAYMENT, RecoverySource.FULFILLMENT)) {
          attempt.escalate();
          attempts.save(attempt);
          alertService.pageOnCall(message.orderId(), attempt.summary());
          return;
      }
39 
      attempts.save(attempt);
      rabbitTemplate.convertAndSend(
              "orders.retry.exchange",
              source.routingKey(),
              message,
              m -> {
                  m.getMessageProperties().setDelayLong(backoffMillis(deaths));
                  return m;
              });
  }
50 
  private long deathCount(List<Map<String, ?>> death) {
      return death == null || death.isEmpty()
              ? 1L
              : ((Number) death.get(0).getOrDefault("count", 1L)).longValue();
  }
56 
  private long backoffMillis(long deaths) {
      return Math.min(Duration.ofMinutes(5).toMillis(), 2000L * (1L << deaths));
  }
60}

01 / 01

STEP 01

Walkthrough

Space play ←→ step click any line

Three takeaways

1Dead-letter queues plus a persisted attempt record let you retry failures safely without losing track of history.
2Capping exponential backoff prevents retry delays from growing unbounded while still spacing out attempts.
3Escalation rules based on death count and cross-source failure stop poison messages from retrying forever.

Related explainers

java

@Component
@Converter
public class EncryptedStringConverter implements AttributeConverter<String, String> {

Transparent column encryption in Spring & JPA

encryption aes-gcm jpa-converter

Advanced 10 steps

java

package com.acme.billing.config;
 
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;

Feature-flagged beans with Spring @ConditionalOnProperty

feature-flags conditional-beans strategy-pattern

Intermediate 5 steps

java

public static Map<String, String> parseCookieHeader(String header) {
    Map<String, String> cookies = new LinkedHashMap<>();
    if (header == null || header.isBlank()) {
        return cookies;

Parsing an HTTP Cookie header in Java

string-parsing http url-decoding

Intermediate 6 steps

java

public class TimedSocketReader {
 
    private static final int READ_TIMEOUT_MS = 5_000;
    private static final int CONNECT_TIMEOUT_MS = 3_000;

Reading a socket with connect and read timeouts

sockets timeouts io

Intermediate 8 steps

java

public final class EncodingDetector {
 
    public enum Encoding {
        UTF_8, UTF_16LE, UTF_16BE, UTF_32LE, UTF_32BE, ASCII, UNKNOWN

Detecting text encoding from raw bytes in Java

byte-manipulation encoding-detection bitwise-operations

Intermediate 8 steps

java

public final class ImportOrganizer {
 
    private static final Pattern IMPORT_LINE =
            Pattern.compile("^import\\s+(static\\s+)?([\\w.]+(?:\\.\\*)?)\\s*;\\s*$");