Package | Description |
---|---|
io.vertx.rxjava.amqpbridge | |
io.vertx.rxjava.core.eventbus | |
io.vertx.rxjava.ext.unit.collect | |
io.vertx.rxjava.servicediscovery.types |
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
AmqpBridge.createConsumer(String amqpAddress)
Creates a consumer on the given AMQP address.
|
Modifier and Type | Field and Description |
---|---|
static TypeArg<MessageConsumer> |
MessageConsumer.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
EventBus.consumer(String address)
Create a message consumer against the specified address.
|
<T> MessageConsumer<T> |
EventBus.consumer(String address,
io.vertx.core.Handler<Message<T>> handler)
Create a consumer and register it against the specified address.
|
MessageConsumer<T> |
MessageConsumer.endHandler(io.vertx.core.Handler<Void> endHandler) |
MessageConsumer<T> |
MessageConsumer.exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
MessageConsumer<T> |
MessageConsumer.fetch(long amount) |
MessageConsumer<T> |
MessageConsumer.handler(io.vertx.core.Handler<Message<T>> handler) |
<T> MessageConsumer<T> |
EventBus.localConsumer(String address)
Like
EventBus.consumer(java.lang.String) but the address won't be propagated across the cluster. |
<T> MessageConsumer<T> |
EventBus.localConsumer(String address,
io.vertx.core.Handler<Message<T>> handler)
Like
EventBus.consumer(java.lang.String) but the address won't be propagated across the cluster. |
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(io.vertx.core.eventbus.MessageConsumer arg) |
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(io.vertx.core.eventbus.MessageConsumer arg,
TypeArg<T> __typeArg_T) |
MessageConsumer<T> |
MessageConsumer.pause() |
MessageConsumer<T> |
MessageConsumer.resume() |
MessageConsumer<T> |
MessageConsumer.setMaxBufferedMessages(int maxBufferedMessages)
Set the number of messages this registration will buffer when this stream is paused.
|
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
EventBusCollector.register(String address)
Register the collector as a consumer of the event bus with the specified address.
|
Modifier and Type | Method and Description |
---|---|
static <T> rx.Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> rx.Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
Modifier and Type | Method and Description |
---|---|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.Handler<io.vertx.core.AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.Handler<io.vertx.core.AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
Copyright © 2019 Eclipse. All rights reserved.