Resultados de la búsqueda a petición "rabbitmq"
Cómo dejar de consumir mensajes con @RabbitListener
Cuando uso MessageListenerAdapter para manejar el mensaje, podría llamar a SimpleMessageListenerContainer.stop () para detener el consumo de la cola. Pero después de cambiar para usar @RabbitListener para escuchar, no puedo encontrar un método ...
SimpMessagingTemplate.convertAndSend con RabbitMQ funciona muy lento
Estoy usando Spring STOMP sobre Websocket con RabbitMQ. Todo funciona bien, pero simpMessagingTemplate.convertAndSend funciona muy lento, la llamada puede demorar de 2 a 10 segundos (sincrónicamente, bloquear el subproceso). ¿Qué puede ser una ...
¿Hay alguna razón para usar RabbitMQ sobre Kafka?
Me pidieron que evaluara RabbitMQ en lugar de Kafka, pero me resultó difícil encontrar una razón por la que está haciendo algo mejor que Kafka. ¿Alguien sabe si es realmente mejor en rendimiento, durabilidad, latencia o facilidad de uso?
¿Cómo usar Rabbit dentro de un archivo gitlab-ci.yml?
Quiero probar congitlab-ci.yml un servidor rpc nameko. No puedo lograr que funcione el Rabitt dentro.gitlab-ci.yml:: :: image: python:latest before_script: - apt-get update -yq - apt-get install -y python-dev python-pip tree - curl ...
Usando RabbitMQ, ¿hay alguna manera de ver el contenido de la cola sin una cola?
Como una forma de aprender RabbitMQ y Python, estoy trabajando en un proyecto que me permite distribuir codificaciones h264 entre varias computadoras. Lo básico está hecho, tengo un demonio que se ejecuta en Linux o Mac que se conecta a la cola, ...
¿Debo cerrar el canal / conexión después de cada publicación?
Estoy usando amqplib en Node.js, y no tengo claras las mejores prácticas en mi código. Básicamente, mi código actual llama alamqp.connect() cuando el servidor Node se inicia y luego usa un canal diferente para cada productor y cada consumidor, ...
Flujo de aire: tareas en cola pero no en ejecución
Soy nuevo en el flujo de aire e intento configurar el flujo de aire para ejecutar tuberías ETL. Pude instalar flujo de airepostgresapiorabbitmqPuedo probar ejecutar el dag turtorial. Cuando intento programar los trabajos, el planificador puede ...
Mensaje retrasado en RabbitMQ
¿Es posible enviar mensajes a través de RabbitMQ con algún retraso? Por ejemplo, quiero expirar la sesión del cliente después de 30 minutos y envío un mensaje que se procesará después de 30 minutos.
spring rabbit amqp @RabbitListener configura el número mínimo y máximo de consumidores
Estoy usando la anotación de spring amqp rabbit @RabbitListener de: artifact spring-rabbit-1.7.1.RELEASE ¿Me pregunto si hay una manera de configurar para cada cola el número de consumidores? He estado buscando en la documentación y todavía no he ...
apio 'Worker-n' pid: xxxx salió con 'exitcode 1' cuando importo hmmlearn
En mi archivo task.py, cuando importo hmmlearn, from hmmlearn import hmmy comienzo mis trabajadores de apio, me sale el siguiente error [2017-06-14 09:18:27,638: INFO/MainProcess] Received ...