Uses of Class
org.eclipse.microprofile.reactive.messaging.Metadata
-
Packages that use Metadata Package Description io.smallrye.reactive.messaging.amqp io.smallrye.reactive.messaging.camel io.smallrye.reactive.messaging.http io.smallrye.reactive.messaging.jms io.smallrye.reactive.messaging.kafka org.eclipse.microprofile.reactive.messaging IMPORTANT This package is a copy from the original package from the specification. -
-
Uses of Metadata in io.smallrye.reactive.messaging.amqp
Fields in io.smallrye.reactive.messaging.amqp declared as Metadata Modifier and Type Field Description protected Metadata
AmqpMessage. metadata
Methods in io.smallrye.reactive.messaging.amqp that return Metadata Modifier and Type Method Description Metadata
AmqpMessage. getMetadata()
Metadata
OutgoingAmqpMessage. getMetadata()
-
Uses of Metadata in io.smallrye.reactive.messaging.camel
Methods in io.smallrye.reactive.messaging.camel that return Metadata Modifier and Type Method Description Metadata
CamelMessage. getMetadata()
-
Uses of Metadata in io.smallrye.reactive.messaging.http
Methods in io.smallrye.reactive.messaging.http that return Metadata Modifier and Type Method Description Metadata
HttpMessage. getMetadata()
-
Uses of Metadata in io.smallrye.reactive.messaging.jms
Methods in io.smallrye.reactive.messaging.jms that return Metadata Modifier and Type Method Description Metadata
IncomingJmsMessage. getMetadata()
-
Uses of Metadata in io.smallrye.reactive.messaging.kafka
Methods in io.smallrye.reactive.messaging.kafka that return Metadata Modifier and Type Method Description Metadata
IncomingKafkaRecord. getMetadata()
Metadata
OutgoingKafkaRecord. getMetadata()
Methods in io.smallrye.reactive.messaging.kafka with parameters of type Metadata Modifier and Type Method Description OutgoingKafkaRecord<K,T>
OutgoingKafkaRecord. withMetadata(Metadata metadata)
Constructors in io.smallrye.reactive.messaging.kafka with parameters of type Metadata Constructor Description OutgoingKafkaRecord(String topic, K key, T value, Instant timestamp, int partition, org.apache.kafka.common.header.Headers headers, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack, Metadata existingMetadata)
-
Uses of Metadata in org.eclipse.microprofile.reactive.messaging
Methods in org.eclipse.microprofile.reactive.messaging that return Metadata Modifier and Type Method Description Metadata
Metadata. copy()
Copies the currentMetadata
instance.static Metadata
Metadata. empty()
Returns an empty set of metadata.static Metadata
Metadata. from(Iterable<Object> iterable)
default Metadata
Message. getMetadata()
static Metadata
Metadata. of(Object... metadata)
Returns an instance ofMetadata
containing multiple values.Metadata
Metadata. with(Object meta)
Creates a new instance ofMetadata
with the current entries, plusmeta
.Metadata
Metadata. without(Class<?> clazz)
Creates a new instance ofMetadata
with the current entries, minus the entry associated with the given class.Methods in org.eclipse.microprofile.reactive.messaging with parameters of type Metadata Modifier and Type Method Description static <T> Message<T>
Message. of(T payload, Metadata metadata)
Create a message with the given payload and metadata.static <T> Message<T>
Message. of(T payload, Metadata metadata, Supplier<CompletionStage<Void>> ack)
Create a message with the given payload, metadata and ack function.static <T> Message<T>
Message. of(T payload, Metadata metadata, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack)
Create a message with the given payload, metadata and ack and nack functions.default Message<T>
Message. withMetadata(Metadata metadata)
Creates a new instance ofMessage
with the specified metadata.
-