Package io.vertx.mutiny.servicediscovery.types

Class EventBusService

java.lang.Object

io.vertx.mutiny.servicediscovery.types.EventBusService

public class EventBusService
extends Object

for event bus services (service proxies). Consumers receive a service proxy to use the service.

NOTE: This class has been automatically generated from the original non Mutiny-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field	Description
static TypeArg<EventBusService>	__TYPE_ARG
static String	TYPE	Name of the type.
static String	UNKNOWN	Unknown type.

Constructor Summary

Constructors

Constructor	Description
EventBusService(io.vertx.servicediscovery.types.EventBusService delegate)
EventBusService(Object delegate)

Method Summary

Modifier and Type	Method	Description
static io.vertx.servicediscovery.Record	createRecord(String name, String address, String classname)
static io.vertx.servicediscovery.Record	createRecord(String name, String address, String itf, io.vertx.core.json.JsonObject metadata)
boolean	equals(Object o)
io.vertx.servicediscovery.types.EventBusService	getDelegate()
static <T> io.smallrye.mutiny.Uni<T>	getServiceProxy(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, Class<T> clientClass)	Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
static <T> io.smallrye.mutiny.Uni<T>	getServiceProxy(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, Class<T> clientClass, io.vertx.core.json.JsonObject conf)	Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
static <T> T	getServiceProxyAndAwait(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, Class<T> clientClass)	Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class).
static <T> T	getServiceProxyAndAwait(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, Class<T> clientClass, io.vertx.core.json.JsonObject conf)	Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class,JsonObject).
static <T> void	getServiceProxyAndForget(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, Class<T> clientClass)	Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class) that ignores the result of the operation.
static <T> void	getServiceProxyAndForget(ServiceDiscovery discovery, Function<io.vertx.servicediscovery.Record,Boolean> filter, Class<T> clientClass, io.vertx.core.json.JsonObject conf)	Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class,JsonObject) that ignores the result of the operation.
static <T> io.smallrye.mutiny.Uni<T>	getServiceProxyWithJsonFilter(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, Class<T> clientClass)	Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
static <T> io.smallrye.mutiny.Uni<T>	getServiceProxyWithJsonFilter(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, Class<T> clientClass, io.vertx.core.json.JsonObject conf)	Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
static <T> T	getServiceProxyWithJsonFilterAndAwait(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, Class<T> clientClass)	Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class).
static <T> T	getServiceProxyWithJsonFilterAndAwait(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, Class<T> clientClass, io.vertx.core.json.JsonObject conf)	Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class,JsonObject).
static <T> void	getServiceProxyWithJsonFilterAndForget(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, Class<T> clientClass)	Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class) that ignores the result of the operation.
static <T> void	getServiceProxyWithJsonFilterAndForget(ServiceDiscovery discovery, io.vertx.core.json.JsonObject filter, Class<T> clientClass, io.vertx.core.json.JsonObject conf)	Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class,JsonObject) that ignores the result of the operation.
int	hashCode()
static EventBusService	newInstance(io.vertx.servicediscovery.types.EventBusService arg)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final TypeArg<EventBusService> __TYPE_ARG

UNKNOWN

public static final String UNKNOWN

Unknown type.

See Also:

Constant Field Values

TYPE

public static final String TYPE

Name of the type.

See Also:

Constant Field Values

Constructor Detail

EventBusService

public EventBusService(io.vertx.servicediscovery.types.EventBusService delegate)

EventBusService

public EventBusService(Object delegate)

Method Detail

getDelegate

public io.vertx.servicediscovery.types.EventBusService getDelegate()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

createRecord

public static io.vertx.servicediscovery.Record createRecord(String name,
                                                            String address,
                                                            String itf,
                                                            io.vertx.core.json.JsonObject metadata)

Parameters:

name - the name of the service.

address - the event bus address on which the service available

itf - the Java interface (name)

metadata - the metadata

Returns:

the created record

getServiceProxy

public static <T> io.smallrye.mutiny.Uni<T> getServiceProxy(ServiceDiscovery discovery,
                                                            Function<io.vertx.servicediscovery.Record,Boolean> filter,
                                                            Class<T> clientClass)

Lookup for a service record and if found, retrieve it and return the service object (used to consume the service). This is a convenient method to avoid explicit lookup and then retrieval of the service. This method requires to have the clientClass set with the expected set of client. This is important for usages not using Java so you can pass the expected type.

Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

Parameters:

discovery - the service discovery

filter - the filter

clientClass - the client class

Returns:

the uni firing the result of the operation when completed, or a failure if the operation failed.

getServiceProxyAndAwait

public static <T> T getServiceProxyAndAwait(ServiceDiscovery discovery,
                                            Function<io.vertx.servicediscovery.Record,Boolean> filter,
                                            Class<T> clientClass)

Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class).

This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

Parameters:

discovery - the service discovery

filter - the filter

clientClass - the client class

Returns:

the T instance produced by the operation.

getServiceProxyAndForget

public static <T> void getServiceProxyAndForget(ServiceDiscovery discovery,
                                                Function<io.vertx.servicediscovery.Record,Boolean> filter,
                                                Class<T> clientClass)

Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class) that ignores the result of the operation.

This method subscribes on the result of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class) but you don't need to compose it with other operations.

Parameters:

discovery - the service discovery

filter - the filter

clientClass - the client class

getServiceProxy

public static <T> io.smallrye.mutiny.Uni<T> getServiceProxy(ServiceDiscovery discovery,
                                                            Function<io.vertx.servicediscovery.Record,Boolean> filter,
                                                            Class<T> clientClass,
                                                            io.vertx.core.json.JsonObject conf)

Lookup for a service record and if found, retrieve it and return the service object (used to consume the service). This is a convenient method to avoid explicit lookup and then retrieval of the service. This method requires to have the clientClass set with the expected set of client. This is important for usages not using Java so you can pass the expected type.

Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

Parameters:

discovery - the service discovery

filter - the filter

clientClass - the client class

conf - the configuration for message delivery

Returns:

the uni firing the result of the operation when completed, or a failure if the operation failed.

getServiceProxyAndAwait

public static <T> T getServiceProxyAndAwait(ServiceDiscovery discovery,
                                            Function<io.vertx.servicediscovery.Record,Boolean> filter,
                                            Class<T> clientClass,
                                            io.vertx.core.json.JsonObject conf)

Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class,JsonObject).

This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

Parameters:

discovery - the service discovery

filter - the filter

clientClass - the client class

conf - the configuration for message delivery

Returns:

the T instance produced by the operation.

getServiceProxyAndForget

public static <T> void getServiceProxyAndForget(ServiceDiscovery discovery,
                                                Function<io.vertx.servicediscovery.Record,Boolean> filter,
                                                Class<T> clientClass,
                                                io.vertx.core.json.JsonObject conf)

Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class,JsonObject) that ignores the result of the operation.

This method subscribes on the result of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class,JsonObject), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxy(io.vertx.mutiny.servicediscovery.ServiceDiscovery,Function,Class,JsonObject) but you don't need to compose it with other operations.

Parameters:

discovery - the service discovery

filter - the filter

clientClass - the client class

conf - the configuration for message delivery

getServiceProxyWithJsonFilter

public static <T> io.smallrye.mutiny.Uni<T> getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
                                                                          io.vertx.core.json.JsonObject filter,
                                                                          Class<T> clientClass)

Lookup for a service record and if found, retrieve it and return the service object (used to consume the service). This is a convenient method to avoid explicit lookup and then retrieval of the service. This method requires to have the clientClass set with the expected set of client. This is important for usages not using Java so you can pass the expected type.

Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

Parameters:

discovery - the service discovery

filter - the filter as json object

clientClass - the client class

Returns:

the uni firing the result of the operation when completed, or a failure if the operation failed.

getServiceProxyWithJsonFilterAndAwait

public static <T> T getServiceProxyWithJsonFilterAndAwait(ServiceDiscovery discovery,
                                                          io.vertx.core.json.JsonObject filter,
                                                          Class<T> clientClass)

Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class).

This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

Parameters:

discovery - the service discovery

filter - the filter as json object

clientClass - the client class

Returns:

the T instance produced by the operation.

getServiceProxyWithJsonFilterAndForget

public static <T> void getServiceProxyWithJsonFilterAndForget(ServiceDiscovery discovery,
                                                              io.vertx.core.json.JsonObject filter,
                                                              Class<T> clientClass)

Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class) that ignores the result of the operation.

This method subscribes on the result of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class) but you don't need to compose it with other operations.

Parameters:

discovery - the service discovery

filter - the filter as json object

clientClass - the client class

getServiceProxyWithJsonFilter

public static <T> io.smallrye.mutiny.Uni<T> getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
                                                                          io.vertx.core.json.JsonObject filter,
                                                                          Class<T> clientClass,
                                                                          io.vertx.core.json.JsonObject conf)

Lookup for a service record and if found, retrieve it and return the service object (used to consume the service). This is a convenient method to avoid explicit lookup and then retrieval of the service. This method requires to have the clientClass set with the expected set of client. This is important for usages not using Java so you can pass the expected type.

Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

Parameters:

discovery - the service discovery

filter - the filter as json object

clientClass - the client class

conf - the configuration for message delivery

Returns:

the uni firing the result of the operation when completed, or a failure if the operation failed.

getServiceProxyWithJsonFilterAndAwait

public static <T> T getServiceProxyWithJsonFilterAndAwait(ServiceDiscovery discovery,
                                                          io.vertx.core.json.JsonObject filter,
                                                          Class<T> clientClass,
                                                          io.vertx.core.json.JsonObject conf)

Blocking variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class,JsonObject).

This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

Parameters:

discovery - the service discovery

filter - the filter as json object

clientClass - the client class

conf - the configuration for message delivery

Returns:

the T instance produced by the operation.

getServiceProxyWithJsonFilterAndForget

public static <T> void getServiceProxyWithJsonFilterAndForget(ServiceDiscovery discovery,
                                                              io.vertx.core.json.JsonObject filter,
                                                              Class<T> clientClass,
                                                              io.vertx.core.json.JsonObject conf)

Variant of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class,JsonObject) that ignores the result of the operation.

This method subscribes on the result of io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class,JsonObject), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from io.vertx.mutiny.servicediscovery.types.EventBusService#getServiceProxyWithJsonFilter(io.vertx.mutiny.servicediscovery.ServiceDiscovery,JsonObject,Class,JsonObject) but you don't need to compose it with other operations.

Parameters:

discovery - the service discovery

filter - the filter as json object

clientClass - the client class

conf - the configuration for message delivery

createRecord

public static io.vertx.servicediscovery.Record createRecord(String name,
                                                            String address,
                                                            String classname)

Parameters:

name - the service name

address - the address

classname - the payload class

Returns:

the record

newInstance

public static EventBusService newInstance(io.vertx.servicediscovery.types.EventBusService arg)