flow {
            aChannel.basicConsume(queueName, autoAck, "myConsumerTag",
                    object : DefaultConsumer(aChannel) {
                        @Throws(IOException::class)
                        override fun handleDelivery(consumerTag: String?,
                                                    envelope: Envelope,
                                                    properties: AMQP.BasicProperties,
                                                    body: ByteArray?) {

                            emit(body)
                        }
                    })
        }