Update examples

Author: Artemyev Vyacheslav

rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/ConsumerExample.kt

@@ -4,37 +4,28 @@ import com.rabbitmq.client.ConnectionFactory
 import com.rabbitmq.client.Delivery
 import io.github.viartemev.rabbitmq.channel.channel
 import io.github.viartemev.rabbitmq.channel.consume
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.async
-import kotlinx.coroutines.awaitAll
-import kotlinx.coroutines.coroutineScope
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.runBlocking
-import kotlinx.coroutines.withContext
+import kotlinx.coroutines.*
 
 const val CONSUMER_QUEUE_NAME = "test_queue"
 const val CONSUME_TIMES = 5
 val ioIntensiveFunction: suspend (Delivery) -> Unit = {
     delay(2000)
     println(message = "Message: ${String(it.body)}")
 }
-val handler: suspend (Delivery) -> Unit = { delivery: Delivery -> withContext(Dispatchers.IO) { ioIntensiveFunction(delivery) } }
+val handler: suspend (Delivery) -> Unit =
+    { delivery: Delivery -> withContext(Dispatchers.IO) { ioIntensiveFunction(delivery) } }
 
-fun main() {
+fun main(): Unit = runBlocking {
     val connectionFactory = ConnectionFactory().apply { useNio() }
-    val connection = connectionFactory.newConnection()
-    runBlocking {
-        connection.channel {
+    connectionFactory.newConnection().use { connction ->
+        connction.channel {
             try {
                 consume(CONSUMER_QUEUE_NAME, 1) {
-                    coroutineScope {
-                        (1..CONSUME_TIMES).map { async { consumeMessageWithConfirm(handler) } }.awaitAll()
-                    }
+                    (1..CONSUME_TIMES).map { async(Dispatchers.IO) { consumeMessageWithConfirm(handler) } }.awaitAll()
                 }
             } catch (e: RuntimeException) {
                 println("Error is here...let's rollback handler actions")
             }
         }
     }
-    connection.close()
 }

rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/PublisherExample.kt

@@ -7,24 +7,26 @@ import io.github.viartemev.rabbitmq.channel.publish
 import io.github.viartemev.rabbitmq.publisher.OutboundMessage
 import io.github.viartemev.rabbitmq.queue.QueueSpecification
 import io.github.viartemev.rabbitmq.queue.declareQueue
-import kotlinx.coroutines.*
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.runBlocking
 
 const val PUBLISHER_EXCHANGE_NAME = ""
 const val PUBLISHER_QUEUE_NAME = "test_queue"
 const val TIMES = 1_000
 
-fun main() = runBlocking {
+fun main(): Unit = runBlocking {
     val connectionFactory = ConnectionFactory().apply { useNio() }
-    val connection = connectionFactory.newConnection()
-    connection.confirmChannel {
-        declareQueue(QueueSpecification(PUBLISHER_QUEUE_NAME)).queue
-        publish {
-            coroutineScope {
-                val messages = (1..TIMES).map { createMessage("") }.map {  publishWithConfirm(it) }
+    connectionFactory.newConnection().use { connection ->
+        connection.confirmChannel {
+            declareQueue(QueueSpecification(PUBLISHER_QUEUE_NAME)).queue
+            publish {
+                (1..TIMES).map { createMessage("") }.map { async(Dispatchers.IO) { publishWithConfirm(it) } }.awaitAll()
+                    .forEach { println(it) }
             }
         }
     }
-    connection.close()
 }
 
 private fun createMessage(body: String) =

rabbitmq-kotlin-example/src/main/kotlin/io/github/viartemev/rabbitmq/example/rpc/RpcClient.kt

@@ -14,9 +14,8 @@ import mu.KotlinLogging
 private val logger = KotlinLogging.logger {}
 
 fun main(): Unit = runBlocking {
-    val connection = ConnectionFactory().apply { useNio() }.newConnection()
     val message = OutboundMessage("", "rpc_request", MessageProperties.PERSISTENT_BASIC, "Slava")
-    connection.use { conn ->
+    ConnectionFactory().apply { useNio() }.newConnection().use { conn ->
         conn.channel {
             logger.info { "Asking for greeting request..." }
             val response = withTimeoutOrNull(1000) {