Tu cola de mensajes garantiza entrega al menos una vez. ¿Qué significa eso para el consumidor que escribes?

Significa que los duplicados son normales, no excepcionales, así que tu consumidor tiene que ser idempotente. Deriva una clave estable del mensaje, guarda las claves procesadas en la misma transacción que el efecto y trata una repetición como una operación nula. Cuenta también con entrega desordenada y con reentrega tras una caída entre hacer el trabajo y confirmar. La entrega exactamente una vez de extremo a extremo no existe entre sistemas; lo que tienes es al menos una vez más un manejo idempotente.

Significa que voy a recibir el mismo mensaje dos veces, normalmente porque el consumidor hizo el trabajo y murió antes de confirmar, así que el broker lo reentrega. Por tanto el consumidor tiene que ser seguro de ejecutar dos veces con la misma entrada. En la práctica tomo un id estable del mensaje y, cuando escribo el efecto, escribo el id procesado en la misma transacción de base de datos, con una restricción de unicidad. Si el insert entra en conflicto, sé que ya lo he tratado y confirmo sin repetir el trabajo. La parte crítica es que el registro de deduplicación y el efecto se confirmen juntos; si los escribo por separado hay una ventana en la que puedo duplicar. También asumo que el orden no está garantizado, así que los manejadores toleran que llegue una actualización antes que la creación, normalmente indexando por la entidad y comprobando una versión. Para los fallos uso un reintento acotado con backoff exponencial y jitter, y luego una cola de mensajes fallidos con alerta, porque reintentar en silencio un mensaje envenenado para siempre es como una cola se atasca de noche.