Resultados de la búsqueda a petición "spring-amqp"
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:
¿Cómo se implementa la concurrencia en Spring AMQP Listener Container?
Mi contenedor de configuración XML: <rabbit:listener-container connection-factory="myConnectionFactory" acknowledge="none" concurrency="10" requeue-rejected="false"> <rabbit:listener ref="myListener" queues="myQueue"/> ...
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 ...
Spring amqp con RabbitMq: el mensaje no vuelve a la cola en vivo después de caerse de la cola de mensajes no entregados
Estoy tratando de lograresta [http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2013-April/026489.html]. Hay tantas respuestas conflictivas para saber si es posible o no. Según el enlace anterior, no es posible. Pero en otra pregunta en este ...
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 ...
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 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 ...
¿Cómo iniciar, detener y volver a conectar los contenedores de escucha spring rabbitmq y sus conexiones?
Tengo una conexión a Internet donde la puerta de enlace de salida cambia periódicamente. Recibo un evento o una notificación de devolución de llamada para mi aplicación de primavera unos segundos antes de que esto suceda. Me gustaría detener a ...