vertx / io.vertx.core.spi.metrics / EventBusMetrics

EventBusMetrics

interface EventBusMetrics<H : Any> : Metrics

The event bus metrics SPI which Vert.x will use to call when each event occurs.

Author
Nick Scavelli

Functions

beginHandleMessage

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.

endHandleMessage

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.

handlerRegistered

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.

handlerUnregistered

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.

messageRead

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.

messageReceived

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.

messageSent

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.

messageWritten

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.

replyFailure

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.

scheduleMessage

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.