Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
En el contexto de las confirmaciones del publisher, al esperar el futuro de CorrelationData (SettableListenableFuture#get()), ¿espera indefinidamente o hay un tiempo de espera configurado internamente?
@EnableRabbit @Service public class RabbitMqListenerWithReply { @Autowired RabbitTemplate rabbitTemplate; @Value(“${test.rabbitmq.exchange}”) private String rabbitMQExchange; @Value(“${test.rabbitmq.routingkey}”) private String rabbitMQRoutingKey; @RabbitListener(queues = “${test.rabbitmq.queue}”) public void receiveMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG)long tag) throws IOException { System.out.println(message.toString()); channel.basicAck(tag, false); System.out.println(“Ackd”); } } Estoy intentando implementar un oyente que reconozca el mensaje después de consumirlo, sin . . . Read more
Hice una aplicación de Spring Batch que produce mensajes AMQP (RabbitMQ) que consisten en una lista de objetos JSON. Los mensajes tienen encabezados con metadatos. La aplicación de Spring Cloud Stream está consumiendo los mensajes y utilicé un enfoque funcional. ¿Cómo puedo acceder a los encabezados? ¿Es una mala práctica . . . Read more
¿Existe un patrón adaptador genérico en spring-cloud que permita publicar/suscribir un mensaje? Básicamente permitiendo cambiar el tipo de proveedor a ampq, kafka, pubsub o jms. El caso de negocio es poder cambiar un servicio de mensajería pub/sub, evitando quedar atrapado con un único proveedor de la nube. Un marco genérico . . . Read more
Preguntado y respondido en respuesta a https://stackoverflow.com/questions/60286491/set-mdc-properties-only-for-rabbitmq-events/60286827#comment124278519_60286827.