Merge pull request #96 from viartemev/add-async-consumer-method

Add async consumer method

Author: viartemev

src/main/kotlin/com/viartemev/thewhiterabbit/consumer/ConfirmConsumer.kt

@@ -5,7 +5,9 @@ import com.rabbitmq.client.Delivery
 import com.viartemev.thewhiterabbit.exception.AcknowledgeException
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.async
 import kotlinx.coroutines.channels.sendBlocking
+import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.withContext
 import mu.KotlinLogging
 import java.io.IOException
@@ -35,8 +37,16 @@ class ConfirmConsumer internal constructor(private val amqpChannel: Channel, amq
     }
 
     /**
-     * Asynchronously consume one message.
-     * @throws IOException if an error is encountered
+     * Consume a message.
+     * @throws com.viartemev.thewhiterabbit.exception.AcknowledgeException if can't send ack
+     */
+    suspend fun asyncConsumeWithConfirm(handler: suspend (Delivery) -> Unit, handlerDispatcher: CoroutineDispatcher = Dispatchers.Default) = coroutineScope {
+        async { consumeWithConfirm(handler, handlerDispatcher) }
+    }
+
+    /**
+     * Consume a message.
+     * @throws com.viartemev.thewhiterabbit.exception.AcknowledgeException if can't send ack
      */
     suspend fun consumeWithConfirm(handler: suspend (Delivery) -> Unit, handlerDispatcher: CoroutineDispatcher = Dispatchers.Default) {
         val delivery = deliveries.receive()