나는 직설적 인 것처럼 느껴지지만 놀랍게도 어려운 일을하려고합니다. 나는 RabbitMQ 대기열에 가입하는 기능이 있습니다. 구체적으로 여기 Channel.consume 함수입니다 : http://www.squaremobius.net/amqp.node/channel_api.html#channel_consume 서브 스크립 션 ID로 해결되는 약속 - 나중에
나는 RabbitMQ에서 메시지를 처리 할 수있는 작업자를 작업 중입니다. 그러나 이것을 수행하는 방법을 잘 모르겠습니다. 메시지를 받았는데 치료하는 동안 오류가 발생하면 어떻게 메시지를 큐 끝에 넣을 수 있습니까? nack을 사용하려고하거나 거부하고 있지만 메시지는 항상 첫 번째 위치에 다시 표시되며 다른 메시지는 계속 고정됩니다. 메시지가 첫 번째
nodejs의 amqplib에 대해 프리 페치 카운트를 1로 설정하려면 어떻게해야합니까? link to Lib on git 원하는 결과는 소비자가 큐 프로세스에서 하나의 메시지 만 처리하고 완료되면 새 메시지를 가져 오는 것입니다. 일부 메시지는 처리하는 데 오랜 시간이 걸리고 다른 메시지는 매우 짧은 시간이 걸리는 설치가 있습니다. 따라서 나는 모든 소비
node-amqp를 사용하려고합니다. 토끼에 대한 연결 섹션에서 예외가 발생하면 예외가 발생하지만 토끼와의 연결이 영원히 다시 시작됩니다. 그 순간 봐 : amqp = require("amqp")
# Open a connection
conn = amqp.createConnection({url: "amqp://localhost"} , {r
nodejs amqplib 모듈을 사용하여 rabbitmq를 연결합니다. 소비 함수가 클로저 함수가된다는 것을 알았지 만 이유를 이해할 수 없습니다. 나는 폐쇄를 사용하지 않았다. 내 코드는 다음과 같습니다. returnOK에서 corr이 여전히 처음 값을 얻은 것을 발견했습니다. 이 기능을 두 번째 발사 할 때. corr은 처음에는 여전히 값입니다. 이상
나는 amqplib을 node.js와 함께 사용하고 있으며, 나는 channels이라는 개념을 확실히 이해하려고 노력하고 있습니다. var amqp = require('amqp/callback_api');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
conne
RabbitMQ 웹 UI 사용 현재 대기열 바인딩이없는 주제 교환에 게시 할 때 rabbitmq는 메시지가 게시되었지만 라우팅되지 않았 음을 나타냅니다. amqp.node를 사용하여 대기열을 Exchange에 바인드하고 "#"(모두)를 사용하여 소비하기 시작하면 아무 것도 얻지 못합니다. 이전에 게시되었지만 라우팅되지 않은 메시지가 표시 될 것으로 예상됩니
node-amqp 라이브러리를 사용하여 RabbitMQ의 여러 소비자를 만들고 싶지만 prefetch-count 옵션이 소비자 당 개수를 나타내는 지 여부를 이해하지 못합니다. 나는 각 소비자가 다른 소비자에 의존하지 않는 자체 프리 페치 횟수를 가지길 원한다. 감사합니다.
클라이언트가 RabbitMQ 대기열에서 메시지를 소비하는 socket.io 서버를 실행하는 node.js 스크립트가 있습니다. 우리는 최근에 Amazon AWS로 마이그레이션했으며 RabbitMQ는 이제 두 대의 시스템 (중복 인스턴스)의 클러스터입니다. AMQP 연결은 때때로 손실됩니다 (중복 VM을 사용하는 고 가용성 환경에서 도달하는 제한이며 이에 대
AMQP 모듈을 사용하여 RabbitMQ에 연결합니다. 연결하고, 교환을 만들고, 대기열에 넣고, 교환에 메시지를 보내고 게시 할 수 있습니다. 메시지가 관리 콘솔에 게시되었는지 확인할 수 있습니다. 문제점 교환 게시 호출에 대한 콜백이 수신되지 않습니다. 이것은 내 코드입니다. 내가 사용하는 메시지를 보낼 필요가있을 때 (앱이 express.js의 인스턴