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.jms
io.smallrye.reactive.messaging.kafka
io.smallrye.reactive.messaging.kafka.fault
io.smallrye.reactive.messaging.mqtt
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 and Description
protected Metadata	AmqpMessage.metadata

Methods in io.smallrye.reactive.messaging.amqp that return Metadata

Modifier and Type	Method and Description
Metadata	AmqpMessage.getMetadata()
Metadata	OutgoingAmqpMessage.getMetadata()

Methods in io.smallrye.reactive.messaging.amqp with parameters of type Metadata

Modifier and Type	Method and Description
CompletionStage<Void>	AmqpMessage.nack(Throwable reason, Metadata metadata)
CompletionStage<Void>	OutgoingAmqpMessage.nack(Throwable reason, Metadata metadata)

Uses of Metadata in io.smallrye.reactive.messaging.camel

Methods in io.smallrye.reactive.messaging.camel that return Metadata

Modifier and Type	Method and Description
Metadata	CamelMessage.getMetadata()

Methods in io.smallrye.reactive.messaging.camel with parameters of type Metadata

Modifier and Type	Method and Description
CompletionStage<Void>	CamelMessage.nack(Throwable reason, Metadata metadata)

Uses of Metadata in io.smallrye.reactive.messaging.jms

Methods in io.smallrye.reactive.messaging.jms that return Metadata

Modifier and Type	Method and 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 and Description
Metadata	OutgoingKafkaRecord.getMetadata()
Metadata	IncomingKafkaRecord.getMetadata()

Methods in io.smallrye.reactive.messaging.kafka with parameters of type Metadata

Modifier and Type	Method and Description
CompletionStage<Void>	IncomingKafkaRecord.nack(Throwable reason, Metadata metadata)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withMetadata(Metadata metadata)

Constructors in io.smallrye.reactive.messaging.kafka with parameters of type Metadata

Constructor and 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 io.smallrye.reactive.messaging.kafka.fault

Methods in io.smallrye.reactive.messaging.kafka.fault with parameters of type Metadata

Modifier and Type	Method and Description
<K,V> CompletionStage<Void>	KafkaFailureHandler.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
<K,V> CompletionStage<Void>	KafkaIgnoreFailure.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
<K,V> CompletionStage<Void>	KafkaFailStop.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)
<K,V> CompletionStage<Void>	KafkaDeadLetterQueue.handle(IncomingKafkaRecord<K,V> record, Throwable reason, Metadata metadata)

Uses of Metadata in io.smallrye.reactive.messaging.mqtt

Methods in io.smallrye.reactive.messaging.mqtt with parameters of type Metadata

Modifier and Type	Method and Description
CompletionStage<Void>	ReceivingMqttMessage.nack(Throwable reason, Metadata metadata)

Uses of Metadata in org.eclipse.microprofile.reactive.messaging

Methods in org.eclipse.microprofile.reactive.messaging that return Metadata

Modifier and Type	Method and Description
Metadata	Metadata.copy() Copies the current Metadata instance.
static Metadata	Metadata.empty() Returns an empty set of metadata.
static Metadata	Metadata.from(Iterable<Object> metadata) Returns an instance of Metadata containing multiple values.
default Metadata	Message.getMetadata()
static Metadata	Metadata.of(Object... metadata) Returns an instance of Metadata containing multiple values.
Metadata	Metadata.with(Object item) Creates a new instance of Metadata with the current entries, plus item.
Metadata	Metadata.without(Class<?> clazz) Creates a new instance of Metadata 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 and Description
default CompletionStage<Void>	Message.nack(Throwable reason, Metadata metadata) Acknowledge negatively this message.
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 of Message with the specified metadata.