Resultados de la búsqueda a petición "amqp"
¿Cómo codificaría un Mapa <Cadena, Objeto> utilizando Búfers de Protocolo?
Estoy tratando de usarProtocol Buffers para la serialización de mensajes.Mi formato de mensaje debe contener entradas de Mapa <Cadena, Objeto> ... pero...
En un sistema FIFO Qeueing, ¿cuál es la mejor manera de implementar la mensajería prioritaria?
Para el middleware orientado a mensajes que no admite constantemente los mensajes de prioridad (como AMQP), ¿cuál es la mejor manera de implementar el consum...
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:
Grupos de mensajes en RabbitMQ / AMQP
ActiveMQ / JMS tiene un mecanismo integrado para garantizar que los mensajes que comparten un encabezado común (a saber, el encabezado JMSXGroupID) siempre s...
¿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"/> ...
¿Esperando todas las respuestas de rabbitmq en un intercambio fanout?
He configurado un intercambio de fanout de rabbitmq llamado "ex_foo"para una carga de trabajo RPC. Cuando los clientes se conectan al servidor, crean su propia cola de recepción RPC no duradera y se conectan a ella con un consumidor básico. Las ...
Cómo solicitar mensajes en RabbitMQ
Después de que el consumidor recibe un mensaje, el consumidor / trabajador realiza algunas validaciones y luego llama al servicio web. En esta fase, si se produce algún error o falla la validación, queremos que el mensaje vuelva a la cola desde ...
RabbitMQ: ¿Cuál es el valor predeterminado de x-message-ttl
No pude encontrar en la documentación de RabbitMQ el valor predeterminado de x-message-ttl viene con la instalación. Sé cómo configurarlo en un valor deseado, pero tengo curiosidad por saber el valor predeterminado.
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 ...