rabbitmq topic 추가

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

@@ -0,0 +1,39 @@
+package kr.co.swh.lecture.opensource.rabbitmq; 
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.rabbitmq 
+ * EmitLogTopic.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 6. 21.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class EmitLogTopic {
+
+  private static final String EXCHANGE_NAME = "news.new";
+
+  public static void main(String[] argv) throws Exception {
+    ConnectionFactory factory = new ConnectionFactory();
+    factory.setHost("dev-swh.ga");
+    try (Connection connection = factory.newConnection();
+         Channel channel = connection.createChannel()) {
+
+        channel.exchangeDeclare(EXCHANGE_NAME, "topic");
+
+        String routingKey = "naver";
+        String message = "뉴스다";
+
+        channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes("UTF-8"));
+        System.out.println(" [x] Sent '" + routingKey + "':'" + message + "'");
+    }
+  }
+  //..
+}

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

@@ -0,0 +1,53 @@
+package kr.co.swh.lecture.opensource.rabbitmq; 
+
+import com.rabbitmq.client.*;
+import java.io.IOException;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.rabbitmq 
+ * ReceiveLogsTopic.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 6. 21.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ReceiveLogsTopic {
+	
+	private static final String EXCHANGE_NAME = "news.new";
+	
+	// argv -> "kern.*" // "*.critical" // "kern.*" "*.critical" // "kern.critical" "A critical kernel error"
+	
+	public static void main(String[] argv) throws Exception {
+		ConnectionFactory factory = new ConnectionFactory();
+		factory.setHost("dev-swh.ga");
+		Connection connection = factory.newConnection();
+		Channel channel = connection.createChannel();
+		
+		channel.exchangeDeclare(EXCHANGE_NAME, "topic");
+		String queueName = channel.queueDeclare().getQueue();
+		
+		String[] bindingKeys = {"naver", "daum"};
+		
+		for (String bindingKey : bindingKeys) {
+			channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);
+		}
+		
+		System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
+		
+		Consumer consumer = new DefaultConsumer(channel) {
+			@Override
+			public void handleDelivery(String consumerTag, Envelope envelope,
+				AMQP.BasicProperties properties, byte[] body) throws IOException {
+				String message = new String(body, "UTF-8");
+				System.out.println(" [x] Received '" + envelope.getRoutingKey() + "':'" + message + "'");
+			}
+		};
+ 
+		channel.basicConsume(queueName, true, consumer);
+	
+	}
+}