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 |