open class MessageConsumer<T : Any> : ReadStream<Message<T>>
An event bus consumer object representing a stream of message to an io.vertx.reactivex.core.eventbus.EventBus address that can be read from.
The io.vertx.reactivex.core.eventbus.EventBus#consumer or io.vertx.reactivex.core.eventbus.EventBus#localConsumer creates a new consumer, the returned consumer is not yet registered against the event bus. Registration is effective after the io.vertx.reactivex.core.eventbus.MessageConsumer#handler method is invoked.
The consumer is unregistered from the event bus using the io.vertx.reactivex.core.eventbus.MessageConsumer#unregister method or by calling the io.vertx.reactivex.core.eventbus.MessageConsumer#handler with a null value..
MessageConsumer(delegate: MessageConsumer<Any>)MessageConsumer(delegate: MessageConsumer<Any>, typeArg_0: TypeArg<T>) |
static val __TYPE_ARG: TypeArg<MessageConsumer<Any>> |
|
val __typeArg_0: TypeArg<T> |
open fun address(): String |
|
open fun bodyStream(): ReadStream<T> |
|
open fun completionHandler(completionHandler: Handler<AsyncResult<Void>>): Unit
Optional method which can be called to indicate when the registration has been propagated across the cluster. |
|
open fun endHandler(endHandler: Handler<Void>): MessageConsumer<T> |
|
open fun equals(other: Any?): Boolean |
|
open fun exceptionHandler(handler: Handler<Throwable>): MessageConsumer<T> |
|
open fun getDelegate(): MessageConsumer<Any> |
|
open fun getMaxBufferedMessages(): Int |
|
open fun handler(handler: Handler<Message<T>>): MessageConsumer<T> |
|
open fun hashCode(): Int |
|
open fun isRegistered(): Boolean |
|
open static fun <T : Any> newInstance(arg: MessageConsumer<Any>): MessageConsumer<T>open static fun <T : Any> newInstance(arg: MessageConsumer<Any>, __typeArg_T: TypeArg<T>): MessageConsumer<T> |
|
open fun pause(): MessageConsumer<T> |
|
open fun resume(): MessageConsumer<T> |
|
open fun rxCompletionHandler(): Completable
Optional method which can be called to indicate when the registration has been propagated across the cluster. |
|
open fun rxUnregister(): Completable
Unregisters the handler which created this registration |
|
open fun setMaxBufferedMessages(maxBufferedMessages: Int): MessageConsumer<T>
Set the number of messages this registration will buffer when this stream is paused. The default value is |
|
open fun toFlowable(): Flowable<Message<T>> |
|
open fun toObservable(): Observable<Message<T>> |
|
open fun toString(): String |
|
open fun unregister(): Unitopen fun unregister(completionHandler: Handler<AsyncResult<Void>>): Unit
Unregisters the handler which created this registration |