Class MessageSource
- java.lang.Object
-
- io.vertx.rxjava3.servicediscovery.types.MessageSource
-
- All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
public class MessageSource extends Object implements io.vertx.lang.rx.RxDelegate
Service type for data producer. Providers are publishing data to a specific event bus address.NOTE: This class has been automatically generated from the
original
non RX-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<MessageSource>
__TYPE_ARG
static String
TYPE
static String
UNKNOWN
Unknown type.
-
Constructor Summary
Constructors Constructor Description MessageSource(MessageSource delegate)
MessageSource(Object delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Record
createRecord(String name, String address)
Same ascreateRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject)
without additional metadata, and no type for the payload.static Record
createRecord(String name, String address, String type)
Same ascreateRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject)
without additional metadata.static Record
createRecord(String name, String address, String type, JsonObject metadata)
Create a record representing a data producer.boolean
equals(Object o)
static <T> Single<MessageConsumer<T>>
getConsumer(ServiceDiscovery discovery, JsonObject filter)
Convenient method that looks for a message source and provides the configured .static <T> Single<MessageConsumer<T>>
getConsumer(ServiceDiscovery discovery, Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .MessageSource
getDelegate()
int
hashCode()
static MessageSource
newInstance(MessageSource arg)
static <T> Single<MessageConsumer<T>>
rxGetConsumer(ServiceDiscovery discovery, JsonObject filter)
Convenient method that looks for a message source and provides the configured .static <T> Single<MessageConsumer<T>>
rxGetConsumer(ServiceDiscovery discovery, Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .String
toString()
-
-
-
Field Detail
-
__TYPE_ARG
public static final io.vertx.lang.rx.TypeArg<MessageSource> __TYPE_ARG
-
UNKNOWN
public static final String UNKNOWN
Unknown type.- See Also:
- Constant Field Values
-
TYPE
public static final String TYPE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
MessageSource
public MessageSource(MessageSource delegate)
-
MessageSource
public MessageSource(Object delegate)
-
-
Method Detail
-
getDelegate
public MessageSource getDelegate()
- Specified by:
getDelegate
in interfaceio.vertx.lang.rx.RxDelegate
-
createRecord
public static Record createRecord(String name, String address, String type, JsonObject metadata)
Create a record representing a data producer.- Parameters:
name
- the name of the serviceaddress
- the address on which the data is senttype
- the type of payload (fully qualified name of the class)metadata
- additional metadata- Returns:
- the created record
-
createRecord
public static Record createRecord(String name, String address, String type)
Same ascreateRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject)
without additional metadata.- Parameters:
name
- the name of the serviceaddress
- the address on which the data is senttype
- the type of payload- Returns:
- the created record
-
createRecord
public static Record createRecord(String name, String address)
Same ascreateRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject)
without additional metadata, and no type for the payload.- Parameters:
name
- the name of the serviceaddress
- the address on which the data is sent.- Returns:
- the created record
-
getConsumer
public static <T> Single<MessageConsumer<T>> getConsumer(ServiceDiscovery discovery, JsonObject filter)
Convenient method that looks for a message source and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.- Parameters:
discovery
- The service discovery instancefilter
- The filter, optional- Returns:
- a future notified with the client
-
rxGetConsumer
public static <T> Single<MessageConsumer<T>> rxGetConsumer(ServiceDiscovery discovery, JsonObject filter)
Convenient method that looks for a message source and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.- Parameters:
discovery
- The service discovery instancefilter
- The filter, optional- Returns:
- a future notified with the client
-
getConsumer
public static <T> Single<MessageConsumer<T>> getConsumer(ServiceDiscovery discovery, Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.- Parameters:
discovery
- The service discovery instancefilter
- The filter, must not benull
- Returns:
- a future notified with the client
-
rxGetConsumer
public static <T> Single<MessageConsumer<T>> rxGetConsumer(ServiceDiscovery discovery, Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured . The async result is marked as failed is there are no matching services, or if the lookup fails.- Parameters:
discovery
- The service discovery instancefilter
- The filter, must not benull
- Returns:
- a future notified with the client
-
newInstance
public static MessageSource newInstance(MessageSource arg)
-
-