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,
Handler<Message<T>> handler)
Create a consumer and register it against the specified address.
|
MessageConsumer<T> |
MessageConsumer.endHandler(Handler<Void> endHandler) |
MessageConsumer<T> |
MessageConsumer.exceptionHandler(Handler<Throwable> handler) |
MessageConsumer<T> |
MessageConsumer.fetch(long amount) |
MessageConsumer<T> |
MessageConsumer.handler(Handler<Message<T>> handler) |
<T> MessageConsumer<T> |
EventBus.localConsumer(String address)
Like
EventBus.consumer(String) but the address won't be propagated across the cluster. |
<T> MessageConsumer<T> |
EventBus.localConsumer(String address,
Handler<Message<T>> handler)
Like
EventBus.consumer(String, Handler) but the address won't be propagated across the cluster. |
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 |
---|---|
MessageConsumer |
MessageConsumer.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(MessageConsumer arg) |
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(MessageConsumer arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Constructor and Description |
---|
MessageConsumer(MessageConsumer delegate) |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
MessageConsumer.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(MessageConsumer arg) |
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(MessageConsumer arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Constructor and Description |
---|
MessageConsumer(MessageConsumer delegate) |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
MessageConsumer.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(MessageConsumer arg) |
static <T> MessageConsumer<T> |
MessageConsumer.newInstance(MessageConsumer arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Constructor and Description |
---|
MessageConsumer(MessageConsumer delegate) |
Modifier and Type | Method and Description |
---|---|
static <T> Future<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
MessageSource.getConsumer(ServiceDiscovery, Function, Handler) but returns a future of the result |
static <T> Future<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter)
Like
MessageSource.getConsumer(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
Modifier and Type | Method and Description |
---|---|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured
MessageConsumer . |
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured
MessageConsumer . |
Modifier and Type | Field and Description |
---|---|
protected MessageConsumer<JsonObject> |
ProxyHandler.consumer |
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<JsonObject> |
ServiceBinder.register(Class<T> clazz,
T service)
Registers a service on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.register(EventBus eventBus,
String address)
Register the proxy handle on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.register(Vertx vertx,
String address,
List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders)
Register the proxy handle on the event bus.
|
<T> MessageConsumer<JsonObject> |
ServiceBinder.registerLocal(Class<T> clazz,
T service)
Registers a local service on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.registerLocal(EventBus eventBus,
String address)
Register the local proxy handle on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.registerLocal(Vertx vertx,
String address,
List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders)
Register the local proxy handle on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
Registers a local service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
Registers a service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceBinder.unregister(MessageConsumer<JsonObject> consumer)
Unregisters a published service.
|
static void |
ProxyHelper.unregisterService(MessageConsumer<JsonObject> consumer)
Deprecated.
Unregisters a published service.
|
Copyright © 2023 Eclipse. All rights reserved.