class Relayer : CoroutineScope (source)
Relays messages between two endpoints, with an interceptor reading passed messages.
bind - the endpoint to bind to
interceptor - the interceptor function consuming messages being relayed
coroutineContext - the coroutine context of the relayer
<init> |
Relays messages between two endpoints, with an interceptor reading passed messages. Relayer(vertx: Vertx, bind: String, to: String, interceptor: (Message) -> Unit, coroutineContext: CoroutineContext = Dispatchers.Default) |
coroutineContext |
the coroutine context of the relayer val coroutineContext: CoroutineContext |
start |
Starts the relayer. suspend fun start(): Unit |
stop |
Stops the relayer. fun stop(): Unit |