4장. 예
이 장에서는 예제 프로그램을 통해 Red Hat build of Rhea를 사용하는 방법을 보여줍니다.
자세한 내용은 Rhea 예제 제품군 및 Rhea 예제 를 참조하십시오.
4.1. 메시지 전송
이 클라이언트 프로그램은 < connection-url >을 사용하여 서버에 연결하고, 대상 < address >에 대한 보낸 사람을 생성하고, < message-body >를 포함하는 메시지를 전송하고, 연결을 종료하고 종료합니다.
예: 메시지 전송
"use strict";
var rhea = require("rhea");
var url = require("url");
if (process.argv.length !== 5) {
console.error("Usage: send.js <connection-url> <address> <message-body>");
process.exit(1);
}
var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var message_body = process.argv[4];
var container = rhea.create_container();
container.on("sender_open", function (event) {
console.log("SEND: Opened sender for target address '" +
event.sender.target.address + "'");
});
container.on("sendable", function (event) {
var message = {
body: message_body
};
event.sender.send(message);
console.log("SEND: Sent message '" + message.body + "'");
event.sender.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_sender(address);
예제 실행
예제 프로그램을 실행하려면 node 명령을 사용하여 로컬 파일에 복사하고 호출합니다. 자세한 내용은 3장. 시작하기의 내용을 참조하십시오.
$ node send.js amqp://localhost queue1 hello
