processMessage

open override fun <R> processMessage(waitTimeoutMs: Long, handler: (msgEnv: MessageEnvelope) -> R): R?