Resultados de la búsqueda a petición "node-amqp"
¿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, ...
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 ...