feat: rabbitmq 기본설정 추가

domain/build.gradle

@@ -2,8 +2,10 @@ dependencies {
     runtimeOnly("mysql:mysql-connector-java")
     developmentOnly("org.springframework.boot:spring-boot-devtools")
     api("org.springframework.boot:spring-boot-starter-data-jpa")
+    implementation("org.springframework.boot:spring-boot-starter-amqp")
     implementation("com.github.ulisesbocchio:jasypt-spring-boot-starter:3.0.3")
     testRuntimeOnly("com.h2database:h2")
+    testImplementation("org.springframework.amqp:spring-rabbit-test")
 }
 
 bootJar {

domain/src/main/kotlin/mashup/backend/spring/member/infrastructure/amqp/AmqpConfig.kt

@@ -0,0 +1,51 @@
+package mashup.backend.spring.member.infrastructure.amqp
+
+import org.springframework.amqp.core.Binding
+import org.springframework.amqp.core.BindingBuilder
+import org.springframework.amqp.core.Queue
+import org.springframework.amqp.core.TopicExchange
+import org.springframework.amqp.rabbit.connection.ConnectionFactory
+import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
+import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+
+@Configuration
+class AmqpConfig {
+    companion object {
+        const val topicExchangeName = "test-exchange"
+        const val queueName = "member"
+    }
+
+    @Bean
+    fun queue(): Queue {
+        return Queue(queueName, false)
+    }
+
+    @Bean
+    fun exchange(): TopicExchange? {
+        return TopicExchange(topicExchangeName)
+    }
+
+    @Bean
+    fun binding(queue: Queue?, exchange: TopicExchange?): Binding {
+        return BindingBuilder.bind(queue).to(exchange).with("member.#")
+    }
+
+    @Bean
+    fun container(
+        connectionFactory: ConnectionFactory,
+        listenerAdapter: MessageListenerAdapter
+    ): SimpleMessageListenerContainer? {
+        val container = SimpleMessageListenerContainer()
+        container.connectionFactory = connectionFactory
+        container.setQueueNames(queueName)
+        container.setMessageListener(listenerAdapter)
+        return container
+    }
+
+    @Bean
+    fun listenerAdapter(receiver: Receiver?): MessageListenerAdapter {
+        return MessageListenerAdapter(receiver, "receiveMessage")
+    }
+}

domain/src/main/kotlin/mashup/backend/spring/member/infrastructure/amqp/Receiver.kt

@@ -0,0 +1,14 @@
+package mashup.backend.spring.member.infrastructure.amqp
+
+import org.springframework.stereotype.Component
+import java.util.concurrent.CountDownLatch
+
+@Component
+class Receiver {
+    val latch = CountDownLatch(1)
+
+    fun receiveMessage(message: String) {
+        println("Received <$message>")
+        latch.countDown()
+    }
+}

domain/src/main/resources/application-local.yml

@@ -5,4 +5,14 @@ spring:
     password: ENC(iff8gDZ+DD3jE5Ekm6WHp8fbilspPmYSuXe1jA2rRPRIjpjhlAVbEjsDk+B0Kbwj)
   jpa:
     hibernate:
-      ddl-auto: update
+      ddl-auto: update
+  rabbitmq:
+    host: b-708a3dff-a404-4fa8-8285-794c9180fcea.mq.ap-northeast-2.amazonaws.com
+    port: 5671
+    username: member
+    password: ENC(yHVJNvwjSH3pzvNvtf1ZgUrn+EsAcjPJOc7tUMAkPMmiSMgo9PXR4ZapTshSq+0D)
+    ssl:
+      enabled: true
+    listener:
+      simple:
+        acknowledge-mode: manual

domain/src/main/resources/application.yml

@@ -1,3 +1,15 @@
 jasypt:
   encryptor:
-    password: # inject from environment variable
+    password: # inject from environment variable
+
+spring:
+  rabbitmq:
+    host: b-708a3dff-a404-4fa8-8285-794c9180fcea.mq.ap-northeast-2.amazonaws.com
+    port: 5671
+    username: member
+    password: ENC(yHVJNvwjSH3pzvNvtf1ZgUrn+EsAcjPJOc7tUMAkPMmiSMgo9PXR4ZapTshSq+0D)
+    ssl:
+      enabled: true
+    listener:
+      simple:
+        acknowledge-mode: manual

domain/src/test/kotlin/mashup/backend/spring/member/infrastructure/amqp/AmqpConfigTest.kt

@@ -0,0 +1,27 @@
+package mashup.backend.spring.member.infrastructure.amqp
+
+import org.junit.jupiter.api.Test
+import org.springframework.amqp.rabbit.core.RabbitTemplate
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
+import java.util.concurrent.TimeUnit
+
+@SpringBootTest
+internal class AmqpConfigTest {
+    @Autowired
+    lateinit var receiver: Receiver
+
+    @Autowired
+    lateinit var rabbitTemplate: RabbitTemplate
+
+    @Test
+    fun test() {
+        println("Sending message...")
+        rabbitTemplate.convertAndSend(
+            AmqpConfig.topicExchangeName,
+            "member.#",
+            "Hello from RabbitMQ!"
+        )
+        receiver.latch.await(10000, TimeUnit.MILLISECONDS)
+    }
+}

domain/src/test/resources/application.yml

@@ -0,0 +1,15 @@
+spring:
+  rabbitmq:
+    host: b-708a3dff-a404-4fa8-8285-794c9180fcea.mq.ap-northeast-2.amazonaws.com
+    port: 5671
+    username: member
+    password: ENC(yHVJNvwjSH3pzvNvtf1ZgUrn+EsAcjPJOc7tUMAkPMmiSMgo9PXR4ZapTshSq+0D)
+    ssl:
+      enabled: true
+    listener:
+      simple:
+        acknowledge-mode: manual
+
+jasypt:
+  encryptor:
+    password: # inject from environment variable