Playground with rabbitmq

docker run -d --hostname rabbit-mq-node --name rabbit-mq-instance -p 15672:15672 -p 5672:5672 rabbitmq:3-management

Author: jmfayard

kotlin-jvm/build.gradle.kts

@@ -30,6 +30,7 @@ dependencies {
     implementation("com.github.kittinunf.fuel:fuel:_")
     implementation("com.github.kittinunf.fuel:fuel-kotlinx-serialization:_")
     implementation("com.h2database:h2:_")
+    implementation("com.rabbitmq:amqp-client:_")
     implementation("com.sksamuel.hoplite:hoplite-core:_")
     implementation("com.sksamuel.hoplite:hoplite-hocon:_")
     implementation("com.sksamuel.hoplite:hoplite-yaml:_")

kotlin-jvm/src/main/kotlin/playground/Konf.kt

@@ -68,7 +68,7 @@ private fun Config.printConfig() {
         Credentials:
         - username: ${this[CredentialsSpec.username]}
         - password: ${this[CredentialsSpec.password]}
-        
+
         Server:
         - domain: ${this[ServerSpec.domain]}
         - protocol: ${this[ServerSpec.protocol]}
@@ -90,4 +90,4 @@ enum class ServerProtocol {
     HTTP, HTTPS
 }
 
-private const val configPath = "configuration"
+private const val configPath = "configuration"

kotlin-jvm/src/main/kotlin/playground/RabbitMQConsumer.kt

@@ -0,0 +1,48 @@
+@file:Suppress("PackageDirectoryMismatch")
+
+package playground.rabbitmq.client
+
+import com.rabbitmq.client.CancelCallback
+import com.rabbitmq.client.Channel
+import com.rabbitmq.client.ConnectionFactory
+import com.rabbitmq.client.DeliverCallback
+import com.rabbitmq.client.Delivery
+import com.uchuhimo.konf.Config
+import playground.rabbitmq.producer.AmqpSpec
+import java.nio.charset.StandardCharsets
+
+fun main() {
+    println()
+    println("# rabbitmq")
+
+    val config = Config {
+        addSpec(AmqpSpec)
+    }
+    val spec = config.from.env()
+    println(spec)
+    val factory = ConnectionFactory()
+    factory.newConnection(spec[AmqpSpec.url]).use { connection ->
+        connection.createChannel().use { channel ->
+            consumeMessage(channel, spec[AmqpSpec.queue])
+        }
+    }
+}
+
+fun consumeMessage(channel: Channel, queueName: String) {
+    val consumerTag = "SimpleConsumer"
+
+    channel.queueDeclare(queueName, false, false, false, null)
+
+    println("[$consumerTag] Waiting for messages...")
+    val deliverCallback = DeliverCallback { consumerTag: String?, delivery: Delivery ->
+        val message = String(delivery.body, StandardCharsets.UTF_8)
+        println("[$consumerTag] Received message: '$message'")
+    }
+    val cancelCallback = CancelCallback { consumerTag: String? ->
+        println("[$consumerTag] was canceled")
+    }
+
+    channel.basicConsume(queueName, true, consumerTag, deliverCallback, cancelCallback)
+
+}
+

kotlin-jvm/src/main/kotlin/playground/RabbitMQProducer.kt

@@ -0,0 +1,38 @@
+@file:Suppress("PackageDirectoryMismatch")
+
+package playground.rabbitmq.producer
+
+import com.rabbitmq.client.ConnectionFactory
+import com.uchuhimo.konf.Config
+import com.uchuhimo.konf.ConfigSpec
+import java.nio.charset.StandardCharsets
+
+fun main() {
+    println()
+    println("# rabbitmq producer")
+
+    val config = Config {
+        addSpec(AmqpSpec)
+    }
+    val spec = config.from.env()
+    println(spec)
+    val factory = ConnectionFactory()
+    factory.newConnection(spec[AmqpSpec.url]).use { connection ->
+        connection.createChannel().use { channel ->
+            channel.queueDeclare(spec[AmqpSpec.queue], false, false, false, null)
+            val message = "Hello World!"
+            channel.basicPublish(
+                "",
+                spec[AmqpSpec.queue],
+                null,
+                message.toByteArray(StandardCharsets.UTF_8)
+            )
+            println(" [x] Sent '$message'")
+        }
+    }
+}
+
+object AmqpSpec : ConfigSpec() {
+    val url by required<String>()
+    val queue by required<String>()
+}

versions.properties

@@ -129,6 +129,8 @@ version.com.jakewharton.retrofit..retrofit2-kotlinx-serialization-converter=0.8.
 
 version.com.nhaarman.mockitokotlin2..mockito-kotlin=2.2.0
 
+version.com.rabbitmq..amqp-client=5.12.0
+
 version.com.sksamuel.hoplite..hoplite-core=1.4.0
 ##                             # available=1.4.1
 
@@ -146,16 +148,24 @@ version.google.android.material=1.3.0
 ##                  # available=1.4.0-alpha01
 ##                  # available=1.4.0-alpha02
 ##                  # available=1.4.0-beta01
+
 version.google.dagger=2.35.1
 ##        # available=2.36
+
 version.io.github.lucapiccinelli..konad=1.2.1
+
 version.io.github.serpro69..kotlin-faker=1.7.1
 ##                           # available=1.8.0-rc.0
+
 version.io.konform..konform=0.3.0
+
 version.it.skrape..skrapeit-core=1.0.0-alpha8
+
 version.it.skrape..skrapeit-http-fetcher=1.1.1
+
 version.junit=5.7.2
 ### available=5.8.0-M1
+
 version.junit.junit=4.13.2
 
 version.kotest=4.4.3