[FEAT] stomp heartbeat setting and change exchange type

HongDam-org · Jun 11, 2024 · 73b32a3 · 73b32a3
1 parent 75d47ec
commit 73b32a3
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/backend/src/main/java/com/twtw/backend/config/rabbitmq/RabbitMQConfig.java b/backend/src/main/java/com/twtw/backend/config/rabbitmq/RabbitMQConfig.java
@@ -57,8 +57,8 @@ public Queue notificationQueue() {
     }
 
     @Bean
-    public TopicExchange notificationTopicExchange() {
-        return new TopicExchange(RabbitMQConstant.NOTIFICATION_EXCHANGE.getName());
+    public DirectExchange notificationTopicExchange() {
+        return new DirectExchange(RabbitMQConstant.NOTIFICATION_EXCHANGE.getName());
     }
 
     @Bean

diff --git a/backend/src/main/java/com/twtw/backend/config/socket/StompConfig.java b/backend/src/main/java/com/twtw/backend/config/socket/StompConfig.java
@@ -16,6 +16,7 @@
 @EnableWebSocketMessageBroker
 public class StompConfig implements WebSocketMessageBrokerConfigurer {
 
+    private static final int HEART_BEAT_INTERVAL = 10_000;
     private final RabbitMQProperties rabbitMQProperties;
 
     @Override
@@ -31,7 +32,9 @@ public void configureMessageBroker(final MessageBrokerRegistry registry) {
                 .setRelayHost(rabbitMQProperties.getHost())
                 .setRelayPort(61613)
                 .setClientPasscode(rabbitMQProperties.getPassword())
-                .setClientLogin(rabbitMQProperties.getUsername());
+                .setClientLogin(rabbitMQProperties.getUsername())
+                .setSystemHeartbeatSendInterval(HEART_BEAT_INTERVAL)
+                .setSystemHeartbeatReceiveInterval(HEART_BEAT_INTERVAL);
 
         registry.setApplicationDestinationPrefixes("/pub");
     }