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 MetadataAmqpMessage. metadataMethods in io.smallrye.reactive.messaging.amqp that return Metadata Modifier and Type Method Description MetadataAmqpMessage. getMetadata()MetadataOutgoingAmqpMessage. 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 MetadataCamelMessage. 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 MetadataHttpMessage. 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 MetadataIncomingJmsMessage. 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 MetadataIncomingKafkaRecord. getMetadata()MetadataOutgoingKafkaRecord. 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 MetadataMetadata. copy()Copies the currentMetadatainstance.static MetadataMetadata. empty()Returns an empty set of metadata.static MetadataMetadata. from(Iterable<Object> iterable)default MetadataMessage. getMetadata()static MetadataMetadata. of(Object... metadata)Returns an instance ofMetadatacontaining multiple values.MetadataMetadata. with(Object meta)Creates a new instance ofMetadatawith the current entries, plusmeta.MetadataMetadata. without(Class<?> clazz)Creates a new instance ofMetadatawith 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 ofMessagewith the specified metadata.
-