Resultados de la búsqueda a petición "amqp"
Usando RabbitMQ (cliente Java), ¿hay alguna manera de determinar si la conexión de red está cerrada durante el consumo?
Estoy usando RabbitMQ en RHEL 5.3 usando el cliente Java. Tengo 2 nodos (máquinas). Node1 está consumiendo mensajes de una cola en Node2 utilizando la clase auxiliar de Java QueueingConsumer. QueueingConsumer consumer = new ...
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.
Conexión del bus de servicio Azure a través del cliente Java
Estoy tratando de conectar el bus de servicio de Azure desde el cliente Java con el protocolo AMQP Sigo las instrucciones en el siguiente ...
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 ...
Suscriptor de AMQP dentro de la aplicación Rails
¿Es posible iniciar un suscriptor de AMQP con mi aplicación Rails? Posiblemente a través de un inicializador o algo. Me gustaría tenerlo funcionando al mismo tiempo que también puede interactuar con los modelos Rails. A continuación se muestra ...
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 ...
AMQP 0-9-1 vs 1-0
Estoy buscando un servicio de mensajería para un nuevo proyecto que tendrá que interconectar algunas aplicaciones C # con algunas aplicaciones Java. Realmente me gusta RabbitMQ porque parece tener un soporte increíble para ambas tecnologías. Veo ...
Ack o Nack en conejo MQ
Estoy usando rabbitMQ, tomo todos los mensajes de la cola con basic_get sin el procedimiento de reconocimiento automático, lo que significa que el mensaje permanecerá en la cola hasta que confirme o bloquee el mensaje. A veces tengo mensajes que ...
Cómo agregar Promise al controlador de eventos en javascript
Ahora quiero envolveramqp [https://github.com/postwait/node-amqp]con promesaQ [https://github.com/kriskowal/q]aquí están los códigos Sender.prototype.createConnection_ = function () { var deferred = Q.defer(); this.con_ = amqp.createConnection( ...
Sobrecarga del consumidor RabbitMQ
He estado leyendo sobre los principios de la confirmación de mensajes AMQP. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artículo realmente útil y bien escrito, pero una cosa en particular sobre ...