interface EventBusMetrics<H : Any> : Metrics
The event bus metrics SPI which Vert.x will use to call when each event occurs.
Author
Nick Scavelli
abstract fun beginHandleMessage(handler: H, local: Boolean): Unit
Called when an handler begin to process a message. The thread model depends on the actual context thats registered the handler. Event loop context This method is invoked with the handler event loop thread. Worker context This method is invoked with a worker thread. |
|
abstract fun endHandleMessage(handler: H, failure: Throwable): Unit
Called when an handler finish to process a message. The thread model depends on the actual context thats registered the handler. Event loop context This method is invoked with the handler event loop thread. Worker context This method is invoked with a worker thread. |
|
abstract fun handlerRegistered(address: String, repliedAddress: String): H
Called when a handler is registered on the event bus. No specific thread and context can be expected when this method is called. |
|
abstract fun handlerUnregistered(handler: H): Unit
Called when a handler has been unregistered from the event bus. No specific thread and context can be expected when this method is called. |
|
abstract fun messageRead(address: String, numberOfBytes: Int): Unit
A message has been received from the network. No specific thread and context can be expected when this method is called. |
|
abstract fun messageReceived(address: String, publish: Boolean, local: Boolean, handlers: Int): Unit
Called when a message is received. No specific thread and context can be expected when this method is called. |
|
abstract fun messageSent(address: String, publish: Boolean, local: Boolean, remote: Boolean): Unit
Called when a message has been sent or published. No specific thread and context can be expected when this method is called. |
|
abstract fun messageWritten(address: String, numberOfBytes: Int): Unit
A message has been sent over the network. No specific thread and context can be expected when this method is called. |
|
abstract fun replyFailure(address: String, failure: ReplyFailure): Unit
Called whenever the event bus delivers a reply failure to the sender/publisher, the io.vertx.core.eventbus.ReplyFailure indicates the nature of the failure. No specific thread and context can be expected when this method is called. |
|
abstract fun scheduleMessage(handler: H, local: Boolean): Unit
Schedule a message for processing. No specific thread and context can be expected when this method is called. |