Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
¿Hay alguna manera de implementar una cola FIFO basada en clave (como el ID de grupo de mensajes de SQS) usando RabbitMQ? Tengo un sistema con múltiples consumidores que procesan mensajes del mismo grupo de forma secuencial, esto se hace utilizando FIFO de SQS con MessageGroupId, pero ahora necesito cambiar . . . Read more
Tengo un método para consumir mensajes en una línea similar como se muestra a continuación: @RabbitListener(queues = “${com.rabbimq.myQueue}”) public void receive(String msg, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException { log.info(“Received msg: {}”,msg); channel.basicAck(tag, false); } Esto funciona bien cuando lo ejecuto como un proyecto de SpringBoot. Pero cuando construyo . . . Read more
Preguntado y respondido en respuesta a https://stackoverflow.com/questions/60286491/set-mdc-properties-only-for-rabbitmq-events/60286827#comment124278519_60286827.
Estoy utilizando Spring Boot con RabbitMq, y surgió una pregunta, ¿hay un número limitado de consumidores que puedo crear? ¿Dónde puedo encontrar este valor?
Cuando el consumidor consume mensajes de la cola, los mensajes se eliminan automáticamente de la cola. Pero quiero almacenarlos en la cola todo el tiempo que quiera. ¿Existe alguna manera en Spring Boot de almacenar los mensajes de RabbitMQ en la cola?