Package | Description |
---|---|
io.smallrye.reactive.messaging.amqp | |
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.
|
Modifier and Type | Field and Description |
---|---|
protected Metadata |
AmqpMessage.metadata |
Modifier and Type | Method and Description |
---|---|
Metadata |
AmqpMessage.getMetadata() |
Metadata |
OutgoingAmqpMessage.getMetadata() |
Modifier and Type | Method and Description |
---|---|
Metadata |
HttpMessage.getMetadata() |
Modifier and Type | Method and Description |
---|---|
Metadata |
IncomingJmsMessage.getMetadata() |
Modifier and Type | Method and Description |
---|---|
Metadata |
OutgoingKafkaRecord.getMetadata() |
Metadata |
IncomingKafkaRecord.getMetadata() |
Modifier and Type | Method and Description |
---|---|
OutgoingKafkaRecord<K,T> |
OutgoingKafkaRecord.withMetadata(Metadata 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> iterable) |
default Metadata |
Message.getMetadata() |
static Metadata |
Metadata.of(Object... metadata)
Returns an instance of
Metadata containing multiple values. |
Metadata |
Metadata.with(Object meta)
Creates a new instance of
Metadata with the current entries, plus meta . |
Metadata |
Metadata.without(Class<?> clazz)
Creates a new instance of
Metadata with the current entries, minus the entry associated with the given class. |
Modifier and Type | Method and 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.
|
default Message<T> |
Message.withMetadata(Metadata metadata)
Creates a new instance of
Message with the specified metadata. |
Copyright © 2018–2020 SmallRye. All rights reserved.