Merge pull request #28 from Pinit-Scheduler/feat/RabbitMQ-큐-정의

Feat/rabbit mq 큐 정의

Author: GoGradually

src/main/java/me/gg/pinit/pinittask/infrastructure/events/schedule/ScheduleRabbitMQConfig.java

@@ -0,0 +1,20 @@
+package me.gg.pinit.pinittask.infrastructure.events.schedule;
+
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.ExchangeBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Declares the schedule event exchange so event publishing succeeds even on a fresh broker.
+ */
+@Configuration
+public class ScheduleRabbitMQConfig {
+
+    @Bean
+    public DirectExchange scheduleDirectExchange() {
+        return ExchangeBuilder.directExchange(ScheduleMessaging.DIRECT_EXCHANGE)
+                .durable(true)
+                .build();
+    }
+}

src/main/java/me/gg/pinit/pinittask/infrastructure/events/task/TaskRabbitMQConfig.java

@@ -0,0 +1,20 @@
+package me.gg.pinit.pinittask.infrastructure.events.task;
+
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.ExchangeBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Declares the task event exchange so publishers don't fail when the broker is empty.
+ */
+@Configuration
+public class TaskRabbitMQConfig {
+
+    @Bean
+    public DirectExchange taskDirectExchange() {
+        return ExchangeBuilder.directExchange(TaskMessaging.DIRECT_EXCHANGE)
+                .durable(true)
+                .build();
+    }
+}