Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<MessageSource> |
__TYPE_ARG |
static String |
TYPE |
static String |
UNKNOWN
Unknown type.
|
Constructor and Description |
---|
MessageSource(MessageSource delegate) |
MessageSource(Object delegate) |
Modifier and Type | Method and Description |
---|---|
static Record |
createRecord(String name,
String address)
Same as
createRecord(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 as
createRecord(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,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
getConsumer(ServiceDiscovery discovery,
JsonObject 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,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
rxGetConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<MessageSource> __TYPE_ARG
public static final String UNKNOWN
public static final String TYPE
public MessageSource(MessageSource delegate)
public MessageSource(Object delegate)
public MessageSource getDelegate()
public static Record createRecord(String name, String address, String type, JsonObject metadata)
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 metadatapublic static Record createRecord(String name, String address, String type)
createRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject)
without additional metadata.name
- the name of the serviceaddress
- the address on which the data is senttype
- the type of payloadpublic static Record createRecord(String name, String address)
createRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject)
without additional metadata, and no type for
the payload.name
- the name of the serviceaddress
- the address on which the data is sent.public static <T> Single<MessageConsumer<T>> getConsumer(ServiceDiscovery discovery, JsonObject filter)
discovery
- The service discovery instancefilter
- The filter, optionalpublic static <T> Single<MessageConsumer<T>> rxGetConsumer(ServiceDiscovery discovery, JsonObject filter)
discovery
- The service discovery instancefilter
- The filter, optionalpublic static <T> Single<MessageConsumer<T>> getConsumer(ServiceDiscovery discovery, java.util.function.Function<Record,Boolean> filter)
discovery
- The service discovery instancefilter
- The filter, must not be null
public static <T> Single<MessageConsumer<T>> rxGetConsumer(ServiceDiscovery discovery, java.util.function.Function<Record,Boolean> filter)
discovery
- The service discovery instancefilter
- The filter, must not be null
public static MessageSource newInstance(MessageSource arg)
Copyright © 2022 Eclipse. All rights reserved.