consume

open suspend override fun consume(onMessage: suspend (QueueMessage) -> Unit)