Persistent сообщения и durable очереди; ack после обработки; idempotent consumer; при необходимости - подтверждение от подписчика (at-least-once). Retry с backoff и DLQ при повторных сбоях.