Resultados de la búsqueda a petición "node-amqp"
RxJS Observable con función de suscriptor asíncrono
Estoy tratando de hacer algo que parece que debería ser sencillo, pero está resultando sorprendentemente difícil. Tengo una función para suscribirme a una cola RabbitMQ. Concretamente, esta es la función Channel.consume ...
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 ...
¿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, ...