Resultados de la búsqueda a petición "spring-amqp"
¿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 ...
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 ...
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 ...
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 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 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 ...
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 ...
¿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), ...
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:
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 ...