receiver

open override fun receiver(subscription: MessageSubscription): MessageReceiver<E>