Resultados de la búsqueda a petición "spring-amqp"
Cómo dejar de consumir mensajes con @RabbitListener
Cuando uso MessageListenerAdapter para manejar el mensaje, podría llamar a SimpleMessageListenerContainer.stop () para detener el consumo de la cola. Pero después de cambiar para usar @RabbitListener para escuchar, no puedo encontrar un método ...
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 ...
spring rabbit amqp @RabbitListener configura el número mínimo y máximo de consumidores
Estoy usando la anotación de spring amqp rabbit @RabbitListener de: artifact spring-rabbit-1.7.1.RELEASE ¿Me pregunto si hay una manera de configurar para cada cola el número de consumidores? He estado buscando en la documentación y todavía no he ...
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 ...
Tamaño de la cola en el cliente Spring AMQP Java
Estoy usando la versión Spring amqp 1.1 como mi cliente Java. Tengo una cola que tiene alrededor de 2000 mensajes. Quiero tener un servicio que verifique el ...
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 ...
¿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 ...
¿Cuál es la diferencia entre el recuento de captación previa vs no ack en rabbitmq
¿Necesito saber cuál es la diferencia entre el recuento de captación previa vs no ack en rabbitmq? También cuál es la diferencia entre las siguientes afirmaciones: si configuro el recuento de captación previa, digamos 10 ¿se crean 10 hilos ...
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), ...