Resultados de la búsqueda a petición "amqp"
usando rabbitmq en android para chatear
Hemos implementado el chat rabbitmq en Android. pero el cliente java de rabbitmq tiene mucha hambre. Hemos utilizado la cola individual de intercambio directo para personas y las claves de enrutamiento individuales. ¿Cuál es el mejor patrón de ...
¿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"/> ...
¿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" ...
¿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 ...
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 ...