update

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

@@ -1,39 +0,0 @@
-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 → src/main/java/kr/co/swh/lecture/opensource/rabbitmq/TopicReceiver.java

@@ -15,7 +15,7 @@ import java.io.IOException;
  * @author : tobby48
  * @version : v1.0
  */
-public class ReceiveLogsTopic {
+public class TopicReceiver {
 	
 	private static final String EXCHANGE_NAME = "news.new";
 	
@@ -30,11 +30,7 @@ public class ReceiveLogsTopic {
 		channel.exchangeDeclare(EXCHANGE_NAME, "topic");
 		String queueName = channel.queueDeclare().getQueue();
 		
-		String[] bindingKeys = {"naver", "daum"};
-		
-		for (String bindingKey : bindingKeys) {
-			channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);
-		}
+		channel.queueBind(queueName, EXCHANGE_NAME, "naverKey");
 		
 		System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
 		

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

@@ -0,0 +1,37 @@
+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 
+ * TopicSender.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 6. 21.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class TopicSender {
+
+	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");
+		Connection connection = factory.newConnection();
+		Channel channel = connection.createChannel();
+		channel.exchangeDeclare(EXCHANGE_NAME, "topic");
+
+		String routingKey = "naverKey";
+		String message = "뉴스다";
+
+		channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes("UTF-8"));
+		System.out.println(" [x] Sent '" + routingKey + "':'" + message + "'");
+	}
+	//..
+}