Resultados de la búsqueda a petición "amqp"
Leyendo desde múltiples colas, RabbitMQ
Soy nuevo en RabbitMQ. Quiero poder manejar la lectura de mensajes sin bloquear cuando hay varias colas (para leer). ¿Alguna entrada sobre cómo puedo hacer eso? // Editar 1 public class Rabbit : IMessageBus { private List<string> publishQ = ...
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 ...
Integración de Spring - Queue / Poller parece agotar la agrupación de subprocesos sin ninguna acción
Tengo una aplicación de integración de Spring, adjunta a un corredor de AMQP.Quiero recibir mensajes de una cola de amqp y actualizar los registros de la bas...
Los mensajes con letras muertas no se envían a la cola original después de ttl
He planeado retrasar el procesamiento de mensajes en la cola siguiendo estos dos enlaces.enlace1 [http://yuserinterface.com/dev/2013/01/08/how-to-schedule-delay-messages-with-rabbitmq-using-a-dead-letter-exchange/] ...
¿Qué es el "modo de entrega" en AMQP?
Entiendo que hay 2 opciones disponibles: "No persistente""Persistente"Pero, ¿qué significa esto realmente? "No persistente" como en: el tejido AMQP intentará entregar el mensaje si no hay consumidores, ¿se eliminará el mensaje? "Persistente" ...
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 ...
¿Puede el consumidor RabbitMQ configurarse para consumir solo un número definido de intentos para el mismo mensaje?
¿RabbitMQ es capaz de alguna manera, puedo definir a mi consumidor que tiene un límite de consumo del mismo mensaje? es decir, mi consumidor haciendo un rech...
¿Cómo compila una extensión PHP en Windows con cygwin / mingw?
Estoy tratando de construir elRabbitMQ PHP wrapper [http://code.google.com/p/php-rabbit/]y elContenedor PHP AMPQ [http://code.google.com/p/php-amqp/]en Windows (64) usando Cygwin. He compilado con éxito la biblioteca C subyacente ...
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.
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 ...