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
originalnon RX-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<MessageSource>__TYPE_ARGstatic StringTYPEstatic StringUNKNOWNUnknown 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 RecordcreateRecord(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 RecordcreateRecord(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 RecordcreateRecord(String name, String address, String type, JsonObject metadata)Create a record representing a data producer.booleanequals(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 .MessageSourcegetDelegate()inthashCode()static MessageSourcenewInstance(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 .StringtoString()
-
-
-
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:
getDelegatein 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)
-
-