configure rabbitMQ ConnectionFactory

src/main/kotlin/eventDemo/configuration/injection/ConfigureDI.kt

@@ -13,10 +13,18 @@ fun appKoinModule(config: Configuration) =
 data class Configuration(
   val redisUrl: String,
   val postgresql: Postgresql,
+  val rabbitmq: RabbitMQ,
 ) {
   data class Postgresql(
     val url: String,
     val username: String,
     val password: String,
   )
+
+  data class RabbitMQ(
+    val url: String,
+    val port: Int,
+    val username: String,
+    val password: String,
+  )
 }

src/main/kotlin/eventDemo/configuration/injection/ConfigureDIInfrastructure.kt

@@ -1,5 +1,6 @@
 package eventDemo.configuration.injection
 
+import com.rabbitmq.client.ConnectionFactory
 import com.zaxxer.hikari.HikariConfig
 import com.zaxxer.hikari.HikariDataSource
 import eventDemo.adapter.infrastructureLayer.event.GameEventBusInMemory
@@ -38,6 +39,16 @@ fun Module.configureDIInfrastructure(config: Configuration) {
       }
   } bind DataSource::class
 
+  single {
+    ConnectionFactory().apply {
+      host = config.rabbitmq.url
+      port = config.rabbitmq.port
+      virtualHost = virtualHost
+      username = config.rabbitmq.username
+      password = config.rabbitmq.password
+    }
+  }
+
   singleOf(::GameEventBusInMemory) bind GameEventBus::class
   singleOf(::GameEventStoreInPostgresql) bind GameEventStore::class
   singleOf(::GameProjectionBusInMemory) bind GameProjectionBus::class

src/main/kotlin/eventDemo/configuration/ktor/ConfigureKoin.kt

@@ -29,6 +29,13 @@ fun ApplicationConfig.configuration() =
         username = getProperty("postgresql.username"),
         password = getProperty("postgresql.password"),
       ),
+    rabbitmq =
+      Configuration.RabbitMQ(
+        url = getProperty("rabbitmq.url"),
+        port = getProperty("rabbitmq.port").toInt(),
+        username = getProperty("rabbitmq.username"),
+        password = getProperty("rabbitmq.password"),
+      ),
   )
 
 private fun ApplicationConfig.getProperty(path: String): String =

src/main/resources/application.conf

@@ -27,3 +27,17 @@ postgresql {
     password = "changeit"
     password = ${?POSTGRESQL_PASSWORD}
 }
+
+rabbitmq {
+    url = "localhost"
+    url = ${?RABBITMQ_URL}
+
+    port = "5672"
+    port = ${?RABBITMQ_PORT}
+
+    username = "event-demo"
+    username = ${?RABBITMQ_USERNAME}
+
+    password = "changeit"
+    password = ${?RABBITMQ_PASSWORD}
+}