4.2. 메시지 수신
이 클라이언트 프로그램은 < connection-url >을 사용하여 서버에 연결하고, 소스 < address > 에 대한 수신자를 생성하고, 종료되거나 < count > 메시지에 도달할 때까지 메시지를 수신합니다.
예: 메시지 수신
"use strict";
var rhea = require("rhea");
var url = require("url");
if (process.argv.length !== 4 && process.argv.length !== 5) {
console.error("Usage: receive.js <connection-url> <address> [<message-count>]");
process.exit(1);
}
var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var desired = 0;
var received = 0;
if (process.argv.length === 5) {
desired = parseInt(process.argv[4]);
}
var container = rhea.create_container();
container.on("receiver_open", function (event) {
console.log("RECEIVE: Opened receiver for source address '" +
event.receiver.source.address + "'");
});
container.on("message", function (event) {
var message = event.message;
console.log("RECEIVE: Received message '" + message.body + "'");
received++;
if (received == desired) {
event.receiver.close();
event.connection.close();
}
});
var opts = {
host: conn_url.hostname,
port: conn_url.port || 5672,
// To connect with a user and password:
// username: "<username>",
// password: "<password>",
};
var conn = container.connect(opts);
conn.open_receiver(address);
예제 실행
예제 프로그램을 실행하려면 Python 명령을 사용하여 로컬 파일에 복사하여 호출합니다. 자세한 내용은 3장. 시작하기의 내용을 참조하십시오.
$ node receive.js amqp://localhost queue1
