Resultados de la búsqueda a petición "spring-amqp"
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 ...
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 ...
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: ...
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 ...
¿Cuándo muere un canal AMQP / RabbitMQ sin conexiones?
Tengo un simple programa de prueba RabbitMQ que pone en cola mensajes al azar, y otro que los lee, todo usando Spring-AMQP. Si el consumidor muere (por ejemplo, eliminando un proceso sin tener la oportunidad de cerrar su conexión o canal), ...
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 ...
Recuperar el número de mensajes no reconocidos en la cola RabbitMQ de Java / Spring
¿Hay alguna forma de devolver el número de mensajes que no se han reconocido?Estoy usando este código para obtener la cantidad de mensajes en la cola:
Spring AMQP: Registre BlockedListener en Connection
Estoy tratando de implementar oyentes bloqueados para RabbitMQ usando RabbitTemplate de Spring AMQP. En mi código, estoy usando el archivo jar de la versión Spring-amqp 1.1.3, mientras que también he examinado la versión 1.3.1 y esto tampoco es ...
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 ...
El envío de acuse de recibo al servidor rabbitmq depende del convertidor y del oyente
En primer lugar, presento el contexto de mi caso: estoy usandospring-boot yspring-rabbitmq. Me está funcionando, debes saber que debo haber implementado un convertidor personalizado para los mensajes recibidos. (1)Desde este convertidor se puede ...