rabbitmq nodejs

src/main/java/kr/co/swh/lecture/opensource/rabbitmq/Publisher.java

@@ -44,7 +44,7 @@ public class Publisher {
 		factory.setHost("dev-swh.ga");
 		Connection connection = factory.newConnection();
 		Channel channel = connection.createChannel();
-		channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+		channel.queueDeclare(QUEUE_NAME, true, false, false, null);
 		
 		String message = "Hello World!";
 		channel.basicPublish("", QUEUE_NAME, null, message.getBytes());

src/main/java/kr/co/swh/lecture/opensource/rabbitmq/Receiver.java

@@ -28,7 +28,7 @@ public class Receiver {
 		factory.setHost("dev-swh.ga");
 		Connection connection = factory.newConnection();
 		Channel channel = connection.createChannel();
-		channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+		channel.queueDeclare(QUEUE_NAME, true, false, false, null);
 		
 		System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
 		Consumer consumer = new DefaultConsumer(channel) {

src/main/nodejs/package.json

@@ -7,8 +7,9 @@
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "dependencies": {
-    "express": "~4.16.4",
+    "amqplib": "^0.5.6",
     "ejs": "~2.4.1",
+    "express": "~4.16.4",
     "mysql": "2.17.1",
     "request": "2.88.0"
   },

src/main/nodejs/rabbitmq-receiver.js

@@ -0,0 +1,40 @@
+/*
+ * npm install amqplib
+ */
+
+var amqp = require('amqplib/callback_api');
+
+const url = 'amqp://dev-swh.ga:5672';
+const queueName = 'hello';
+
+amqp.connect(url, function(error, connect){
+    if(error){
+        console.log(error);
+        return;
+    }
+    connect.createChannel(function(error, channel){
+        if(error){
+            console.log(error);
+            return;
+        }
+        channel.assertQueue(queueName, {durable: true}, function(error){
+            let recevieMessage = function(){
+                channel.get(queueName, {}, function(error, message){
+                    if(error){
+                        console.log(error);
+                    }
+                    else if(message){
+                        console.log(message.content.toString());
+                        channel.ack(message);
+                        setTimeout(recevieMessage, 5000);
+                    }
+                    else{
+                        console.log('NO MESSAGE');
+                        setTimeout(recevieMessage, 5000);
+                    }
+                });
+            }
+            recevieMessage();
+        });
+    });
+});

src/main/nodejs/rabbitmq-sender.js

@@ -0,0 +1,39 @@
+/*
+ * npm install amqplib
+ */
+
+var amqp = require('amqplib/callback_api');
+
+const url = 'amqp://dev-swh.ga:5672';
+const queueName = 'hello';
+
+amqp.connect(url, function(error, connect){
+    if(error){
+        console.log(error);
+        return;
+    }
+    connect.createChannel(function(error, channel){
+        if(error){
+            console.log(error);
+            return;
+        }
+        channel.assertQueue(queueName, {durable: true}, function(error){
+            let sendData = {
+                type : 'message',
+                message : 'test message!'
+            };
+            channel.sendToQueue(queueName, encode(sendData), {
+                persistent: true
+            });
+            
+        });
+    });
+});
+
+function encode(doc) {  
+//    return new Buffer(JSON.stringify(doc));
+//	https://stackoverflow.com/questions/52165333/deprecationwarning-buffer-is-deprecated-due-to-security-and-usability-issues
+//	new Buffer(string)            // Old
+//	Buffer.from(string)           // New
+	return Buffer.from(JSON.stringify(doc));
+}