step4 뉴스 구독 예제

villainscode · villainscode · commit baaac54ba0b4 · 2024-12-09T23:11:09.000+09:00
diff --git a/src/main/java/net/harunote/hellomessagequeue/step4/NewsController.java b/src/main/java/net/harunote/hellomessagequeue/step4/NewsController.java
@@ -19,6 +19,7 @@ public void handleSubscribe(@Header("newsType") String newsType) {
         System.out.println("[#] newsType: " + newsType);
 
         String newsMessage = newsPublisher.publish(newsType);
+        System.out.println("# newsMessage: " + newsMessage);
 
     }
 }
diff --git a/src/main/java/net/harunote/hellomessagequeue/step4/RabbitMQConfig.java b/src/main/java/net/harunote/hellomessagequeue/step4/RabbitMQConfig.java
@@ -10,12 +10,13 @@
 @Configuration
 public class RabbitMQConfig {
 
-    // step3-2 예제 추가
+    // step4 예제 추가
     public static final String FANOUT_EXCHANGE_FOR_NEWS = "newsExchange";
 
     public static final String JAVA_QUEUE = "javaQueue";
     public static final String SPRING_QUEUE = "springQueue";
     public static final String VUE_QUEUE = "vueQueue";
+
     @Bean
     public Queue javaQueue() {
         return new Queue(JAVA_QUEUE, false);

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,7 @@ public void handleSubscribe(@Header("newsType") String newsType) {`
`19`	`19`	`System.out.println("[#] newsType: " + newsType);`
`20`	`20`
`21`	`21`	`String newsMessage = newsPublisher.publish(newsType);`
	`22`	`+ System.out.println("# newsMessage: " + newsMessage);`
`22`	`23`
`23`	`24`	`}`
`24`	`25`	`}`