Resultados da pesquisa a pedido "node-amqp"
Devo fechar o canal / conexão após cada publicação?
Estou usando o amqplib no Node.js e não sou claro sobre as práticas recomendadas no meu código. Basicamente, meu código atual chama oamqp.connect() quando o servidor Nó é inicializado e, em seguida, usa um canal diferente para cada produtor ...
Enviar mensagens RabbitMQ através de websockets
Procurando alguns exemplos de código para resolver esse problema: - Gostaria de escrever algum código (Python ou Javascript) que atuaria como assinante de uma fila RabbitMQ para que, ao receber uma mensagem, transmitisse a mensagem via ...
Observável RxJS com função de assinante assíncrona
Estou tentando fazer algo que parece ser direto, mas está se mostrando surpreendentemente difícil. Eu tenho uma função para assinar uma fila RabbitMQ. Concretamente, esta é a função Channel.consume ...
Como reencaminhar mensagens no RabbitMQ
Depois que o consumidor recebe uma mensagem, o consumidor / trabalhador faz algumas validações e depois chama o serviço da web. Nesta fase, se ocorrer algum erro ou a validação falhar, queremos que a mensagem volte à fila em que foi originalmente ...