From f7066a08e4a7a112bc1d26f8fafb997027a49a1a Mon Sep 17 00:00:00 2001 From: github-actions <> Date: Mon, 11 Mar 2024 10:20:53 +0000 Subject: [PATCH] Google Java Format --- .../backend/config/rabbitmq/RabbitMQConfig.java | 16 ++++++++++++---- .../domain/deadletter/DeadLetterConsumer.java | 4 +++- .../notification/messagequeue/FcmConsumer.java | 3 ++- 3 files changed, 17 insertions(+), 6 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 index 9ffd053..ea5d8f3 100644 --- a/backend/src/main/java/com/twtw/backend/config/rabbitmq/RabbitMQConfig.java +++ b/backend/src/main/java/com/twtw/backend/config/rabbitmq/RabbitMQConfig.java @@ -3,7 +3,9 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.twtw.backend.global.constant.RabbitMQConstant; import com.twtw.backend.global.properties.RabbitMQProperties; + import lombok.RequiredArgsConstructor; + import org.springframework.amqp.core.*; import org.springframework.amqp.rabbit.annotation.EnableRabbit; import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; @@ -25,8 +27,11 @@ public class RabbitMQConfig { @Bean public Queue locationQueue() { return QueueBuilder.durable(RabbitMQConstant.LOCATION_QUEUE.getName()) - .withArgument("x-dead-letter-exchange", RabbitMQConstant.DEAD_LETTER_EXCHANGE.getName()) - .withArgument("x-dead-letter-routing-key", RabbitMQConstant.DEAD_LETTER_ROUTING_KEY.getName()) + .withArgument( + "x-dead-letter-exchange", RabbitMQConstant.DEAD_LETTER_EXCHANGE.getName()) + .withArgument( + "x-dead-letter-routing-key", + RabbitMQConstant.DEAD_LETTER_ROUTING_KEY.getName()) .build(); } @@ -45,8 +50,11 @@ public Binding locationBinding() { @Bean public Queue notificationQueue() { return QueueBuilder.durable(RabbitMQConstant.NOTIFICATION_QUEUE.getName()) - .withArgument("x-dead-letter-exchange", RabbitMQConstant.DEAD_LETTER_EXCHANGE.getName()) - .withArgument("x-dead-letter-routing-key", RabbitMQConstant.DEAD_LETTER_ROUTING_KEY.getName()) + .withArgument( + "x-dead-letter-exchange", RabbitMQConstant.DEAD_LETTER_EXCHANGE.getName()) + .withArgument( + "x-dead-letter-routing-key", + RabbitMQConstant.DEAD_LETTER_ROUTING_KEY.getName()) .build(); } diff --git a/backend/src/main/java/com/twtw/backend/domain/deadletter/DeadLetterConsumer.java b/backend/src/main/java/com/twtw/backend/domain/deadletter/DeadLetterConsumer.java index 5c64a87..aa40046 100644 --- a/backend/src/main/java/com/twtw/backend/domain/deadletter/DeadLetterConsumer.java +++ b/backend/src/main/java/com/twtw/backend/domain/deadletter/DeadLetterConsumer.java @@ -1,6 +1,7 @@ package com.twtw.backend.domain.deadletter; import lombok.extern.slf4j.Slf4j; + import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; @@ -21,7 +22,8 @@ public DeadLetterConsumer(@Value("${slack.url}") final String slackUrl) { @RabbitListener(queues = "deadletter.queue") public void handleDeadLetterMessage(final String message) { log.error("Dead letter received: {}", message); - webClient.post() + webClient + .post() .uri(slackUrl) .bodyValue("{\"text\": \"Dead letter received: " + message + "\"}") .retrieve() diff --git a/backend/src/main/java/com/twtw/backend/domain/notification/messagequeue/FcmConsumer.java b/backend/src/main/java/com/twtw/backend/domain/notification/messagequeue/FcmConsumer.java index 5674b15..93b8c1d 100644 --- a/backend/src/main/java/com/twtw/backend/domain/notification/messagequeue/FcmConsumer.java +++ b/backend/src/main/java/com/twtw/backend/domain/notification/messagequeue/FcmConsumer.java @@ -19,7 +19,8 @@ public FcmConsumer(FirebaseMessaging firebaseMessaging) { } @RabbitListener(queues = "notification.queue") - public void sendNotification(final NotificationRequest request) throws FirebaseMessagingException { + public void sendNotification(final NotificationRequest request) + throws FirebaseMessagingException { firebaseMessaging.send(request.toMessage()); } }