From 9b715aa069bd5e587fe1912c5891ff158b6112a9 Mon Sep 17 00:00:00 2001 From: Park seong ho Date: Fri, 2 May 2025 21:53:40 +0900 Subject: [PATCH] =?UTF-8?q?[FEATURE]=20Amazon=20MQ=EC=99=80=20STOMP=20?= =?UTF-8?q?=EB=A9=94=EC=8B=9C=EC=A7=95=20=EC=97=B0=EA=B2=B0=20=EC=84=A4?= =?UTF-8?q?=EC=A0=95=20=EB=B3=80=EA=B2=BD=20#275?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tablenow/global/config/WebSocketConfig.java | 11 +++++++++-- src/main/resources/application-local.yml | 10 +++++++--- 2 files changed, 16 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/example/tablenow/global/config/WebSocketConfig.java b/src/main/java/org/example/tablenow/global/config/WebSocketConfig.java index 6a2cba39..ce24c7c4 100644 --- a/src/main/java/org/example/tablenow/global/config/WebSocketConfig.java +++ b/src/main/java/org/example/tablenow/global/config/WebSocketConfig.java @@ -27,6 +27,13 @@ public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { private final JwtHandshakeInterceptor jwtHandshakeInterceptor; private final RabbitMQProperties rabbitMQProperties; + @Value("${spring.rabbitmq.host}") + private String rabbitMqHost; + + @Value("${spring.rabbitmq.port}") + private int rabbitMqPort; + + @Value("${chat.broker}") private String brokerType; @@ -49,8 +56,8 @@ public void configureMessageBroker(MessageBrokerRegistry registry) { } else if ("rabbit".equalsIgnoreCase(brokerType)) { // [RabbitMQ Relay] MQ로 relay registry.enableStompBrokerRelay(WebSocketConstants.TOPIC_PREFIX_RELAY) - .setRelayHost("localhost") // RabbitMQ 서버 주소 - .setRelayPort(61613) // RabbitMQ STOMP 포트 (TCP) + .setRelayHost(rabbitMqHost) // RabbitMQ 서버 주소 + .setRelayPort(rabbitMqPort) // RabbitMQ STOMP 포트 (TCP) .setSystemLogin(rabbitMQProperties.getUsername()) .setSystemPasscode(rabbitMQProperties.getPassword()) .setClientLogin(rabbitMQProperties.getUsername()) diff --git a/src/main/resources/application-local.yml b/src/main/resources/application-local.yml index 043a4d65..1a7be4d5 100644 --- a/src/main/resources/application-local.yml +++ b/src/main/resources/application-local.yml @@ -53,10 +53,12 @@ spring: type: redis rabbitmq: - host: localhost - port: 5672 + host: ${RABBITMQ_HOST} + port: ${RABBITMQ_PORT} username: ${RABBITMQ_USER} password: ${RABBITMQ_PASSWORD} + ssl: + enabled: ${RABBITMQ_SSL} redisson: config: @@ -64,4 +66,6 @@ redisson: address: "redis://localhost:6379" chat: - broker: rabbit # or simple \ No newline at end of file + broker: rabbit # or simple + +