Resultados de la búsqueda a petición "spring-amqp"
Spring AMQP v1.4.2 - Problema de reconexión de conejo en falla de red
Estoy probando el siguiente escenario en Spring AMQP v1.4.2 y no se puede volver a conectar después de una interrupción de la red: Inicie la aplicación Spring que consume mensajes de forma asíncrona usando rabbit: listener-container y rabbit: ...
Prueba de integración RabbitMQ y subprocesos
He escrito un consumidor RabbitMQ implementando la interfaz MessageListener y configurando un SimpleMessageListenerContainer. Funciona bien cuando lo pruebo manualmente. Ahora me gustaría escribir una prueba de integración que: Crea un ...
rabbitmq con spring amqp: mensajes bloqueados en caso de AmqpException
Estoy lanzando una AmqpException dentro de mi consumidor. Mi expectativa es que el mensaje volverá a la cola en orden FIFO y será reprocesado en algún momento en el futuro. Parece que Spring AMQP no devuelve el mensaje a la cola. Pero, en ...
SimpleMessageListenerContainer Manejo de errores
Estoy usando unSimpleMessageListenerContainer como base para la comunicación remota sobre AMQP. Todo transcurre sin problemas siempre que se pueda acceder al corredor RabbitMQ al inicio del proceso. Sin embargo, si por algún motivo no se puede ...
Proyecto Spring AMQP con 2 colas
Estoy trabajando en un proyecto que involucra 2 colas y múltiples oyentes que interactúan con ellos. Fluir: La nueva solicitud HTTP llega al servidor, luego se convierte en un Objeto que será el mensajeEste mensaje debe publicarse en dos ...
¿Cómo nos conectamos al procesamiento de mensajes antes / después usando @RabbitListener?
Problema:Estoy migrando de la interfaz de MessageListener implícitamente a @RabbitListener. Tenía una lógica como esta donde estaba haciendo el procesamiento de mensajes "pre" y "post" en un MessageListener que fue heredado por varias ...
Cómo lograr concurrencia con un oyente de mensajes no seguro para subprocesos
La respuesta aesta pregunta [https://stackoverflow.com/questions/23341811/how-is-concurrency-in-spring-amqp-listener-container-implemented] explica cómo usar el alcance del prototipo con<rabbit:listener-container/> en Spring AMQP cuando el oyente ...
Mensajes programados / retrasados en Spring AMQP RabbitMq
Estoy luchando por encontrar el camino para los mensajes programados / retrasados en Spring AMQP / Rabbit MQ. Después de mucho buscar todavía no puedo hacer eso en Spring AMQP. ¿Puede alguien decirme cómo hacerlo?x-delay en primavera AMQP. Quiero ...
Autorización OAuth2 con Spring Security y Rabbitmq
Actualmente tenemos varios microservicios Spring que se comunican con puntos finales REST y colas RabbitMQ. Acabamos de implementar la seguridad OAuth2 en todos los servicios, y los puntos finales REST están debidamente protegidos. Tenemos una ...
RabbitMQ basic.get y reconocimiento
Estoy invocando: GetResponse response = channel.basicGet("some.queue", false); // no auto-ack .... channel.basicAck(deliveryTag, ...); Sin embargo, cuando invocobasicGet, los mensajes en la cola permanecen en "Listo", en lugar de en "No ...