#16 fix: PartychattingQueue 라우팅 키 #으로 수정

Geek-sasaeng · Nov 7, 2022 · 5e873ef · 5e873ef
1 parent de0b49f
commit 5e873ef
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/src/main/java/shop/geeksasangchat/rabbitmq/PartyChattingQueue.java b/src/main/java/shop/geeksasangchat/rabbitmq/PartyChattingQueue.java
@@ -18,7 +18,7 @@ public class PartyChattingQueue {
 
     static final String EXCHANGE_NAME = "chatting-room-exchange-test2";
     static final String QUEUE_NAME = "chatting-room-queue-test2";
-    static final String ROUTING_KEY = "chatting.test.room.6364eb74fad92030c4841893"; // 라우팅 키, publishing 하는 방법을 결정.
+    static final String ROUTING_KEY = "chatting.test.room.#"; // 라우팅 키, publishing 하는 방법을 결정.
 
     public PartyChattingQueue(RabbitTemplate rabbitTemplate ) {
         this.rabbitTemplate = rabbitTemplate;

diff --git a/src/main/java/shop/geeksasangchat/rabbitmq/RabbitMqConfig.java b/src/main/java/shop/geeksasangchat/rabbitmq/RabbitMqConfig.java
@@ -1,5 +1,6 @@
 package shop.geeksasangchat.rabbitmq;
 
+import com.rabbitmq.client.impl.AMQImpl;
 import lombok.RequiredArgsConstructor;
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
@@ -75,12 +76,6 @@ public Queue PartyChattingRoomQueueTest2() {
         System.out.println("=========chattingRoomQueue 큐 생성 및 빈 등록======");
         return new Queue("chatting-room-queue-test2");
     }
-//
-//    @Bean
-//    public Queue PartyChattingRoomQueueTest5() {
-//        System.out.println("=========chattingRoomQueue5 큐 생성 및 빈 등록======");
-//        return new Queue("chatting-room-queue-test5");
-//    }
 
     @Bean
     public TopicExchange PartyChattingRoomTopicTest2() {

diff --git a/src/main/java/shop/geeksasangchat/service/PartyChattingService.java b/src/main/java/shop/geeksasangchat/service/PartyChattingService.java
@@ -1,8 +1,13 @@
 package shop.geeksasangchat.service;
 
+import com.rabbitmq.client.AMQP;
 import lombok.RequiredArgsConstructor;
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import shop.geeksasangchat.domain.Chatting;