Uses of Interface
org.eclipse.microprofile.reactive.messaging.Message

Packages that use Message

Package	Description
io.smallrye.reactive.messaging
io.smallrye.reactive.messaging.connector
io.smallrye.reactive.messaging.kafka.api
io.smallrye.reactive.messaging.keyed
io.smallrye.reactive.messaging.observation
org.eclipse.microprofile.reactive.messaging	IMPORTANT This package is a copy from the original package from the specification.
org.eclipse.microprofile.reactive.messaging.spi	The MicroProfile Reactive Messaging API Connector SPI

Uses of Message in io.smallrye.reactive.messaging

Subinterfaces of Message in io.smallrye.reactive.messaging

Modifier and Type	Interface	Description
interface	TargetedMessages	Container of Messages to send multiple messages to different channels

Classes in io.smallrye.reactive.messaging that implement Message

Modifier and Type	Class	Description
static class	TargetedMessages.Default	Default TargetedMessages implementation

Methods in io.smallrye.reactive.messaging with type parameters of type Message

Modifier and Type	Method	Description
<M extends Message<? extends T>> void	MutinyEmitter.send(M msg)	Deprecated. use {MutinyEmitter.sendMessageAndForget(Message)}
<M extends Message<? extends T>> io.smallrye.mutiny.Uni<Void>	MutinyEmitter.sendMessage(M msg)	Sends a message to the channel.
<M extends Message<? extends T>> void	MutinyEmitter.sendMessageAndAwait(M msg)	Sends a message to the channel.
<M extends Message<? extends T>> io.smallrye.mutiny.subscription.Cancellable	MutinyEmitter.sendMessageAndForget(M msg)	Sends a message to the channel without waiting for acknowledgement.

Methods in io.smallrye.reactive.messaging that return Message

Modifier and Type	Method	Description
default Message<?>	IncomingInterceptor.afterMessageReceive(Message<?> message)	Called after message received
default Message<?>	OutgoingInterceptor.beforeMessageSend(Message<?> message)	Called before message transmission
Message<?>	MessageConverter.convert(Message<?> in, Type target)	Converts the given message in into a Message<T>.
Message<?>	MessageConverter.IdentityConverter.convert(Message<?> in, Type target)
Message<?>	TargetedMessages.Default.get(String channel)
Message<?>	TargetedMessages.get(String channel)	Return the message associated with the given channel
static <T> Message<T>	Messages.merge(List<Message<?>> list, Function<List<?>,T> combinator)	Merges multiple messages into a single one.
static <T> Message<List<T>>	Messages.merge(List<Message<T>> list)	Merges multiple messages into a single one.
default Message<?>	OutgoingInterceptor.onMessage(Message<?> message)	Deprecated. use OutgoingInterceptor.beforeMessageSend(Message)
Message<T>	GenericPayload.toMessage()	Converts this payload to a message.
Message<T>	GenericPayload.toMessage(Message<?> message)	Converts this payload to a message, merging the metadata with the given message.

Methods in io.smallrye.reactive.messaging that return types with arguments of type Message

Modifier and Type	Method	Description
default io.smallrye.mutiny.Multi<? extends Message<?>>	PublisherDecorator.decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, String channelName, boolean isConnector)	Deprecated. replaced with PublisherDecorator.decorate(Multi, List, boolean)
default io.smallrye.mutiny.Multi<? extends Message<?>>	PublisherDecorator.decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, List<String> channelName, boolean isConnector)	Decorate a Multi
io.smallrye.mutiny.Multi<? extends Message<?>>	SubscriberDecorator.decorate(io.smallrye.mutiny.Multi<? extends Message<?>> toBeSubscribed, List<String> channelName, boolean isConnector)	Decorate a Multi
Map<String,Message<?>>	TargetedMessages.Default.getPayload()
Flow.Publisher<Message<? extends T>>	MessagePublisherProvider.getPublisher()
List<Flow.Publisher<? extends Message<?>>>	ChannelRegistry.getPublishers(String name)
List<Flow.Subscriber<? extends Message<?>>>	ChannelRegistry.getSubscribers(String name)
Flow.Publisher<? extends Message<?>>	ChannelRegistry.register(String name, Flow.Publisher<? extends Message<?>> stream, boolean broadcast)
Flow.Subscriber<? extends Message<?>>	ChannelRegistry.register(String name, Flow.Subscriber<? extends Message<?>> subscriber, boolean merge)
List<Message<?>>	Messages.MessageChainBuilder.with(Message<?>... messages)	Chain the passed array of messages.

Methods in io.smallrye.reactive.messaging with parameters of type Message

Modifier and Type	Method	Description
default Message<?>	IncomingInterceptor.afterMessageReceive(Message<?> message)	Called after message received
default Message<?>	OutgoingInterceptor.beforeMessageSend(Message<?> message)	Called before message transmission
boolean	MessageConverter.canConvert(Message<?> in, Type target)	Checks whether this instance of converter can convert the given message in into a Message<T> with T being the type represented by target.
boolean	MessageConverter.IdentityConverter.canConvert(Message<?> in, Type target)
static Messages.MessageChainBuilder	Messages.chain(Message<?> message)	Chains the given message with some other messages.
Message<?>	MessageConverter.convert(Message<?> in, Type target)	Converts the given message in into a Message<T>.
Message<?>	MessageConverter.IdentityConverter.convert(Message<?> in, Type target)
static <T> GenericPayload<T>	GenericPayload.from(Message<T> message)	Creates a new payload from the given message.
static Optional<TracingMetadata>	TracingMetadata.fromMessage(Message<?> message)	Retrieves the tracing metadata from inside the Metadata of a Message.
static TargetedMessages	TargetedMessages.of(String channel, Message<?> message)
static TargetedMessages	TargetedMessages.of(String c1, Message<?> m1, String c2, Message<?> m2)
static TargetedMessages	TargetedMessages.of(String c1, Message<?> m1, String c2, Message<?> m2, String c3, Message<?> m3)
static TargetedMessages	TargetedMessages.of(String c1, Message<?> m1, String c2, Message<?> m2, String c3, Message<?> m3, String c4, Message<?> m4)
static TargetedMessages	TargetedMessages.of(String c1, Message<?> m1, String c2, Message<?> m2, String c3, Message<?> m3, String c4, Message<?> m4, String c5, Message<?> m5)
static TargetedMessages	TargetedMessages.of(String c1, Message<?> m1, String c2, Message<?> m2, String c3, Message<?> m3, String c4, Message<?> m4, String c5, Message<?> m5, String c6, Message<?> m6)
default Message<?>	OutgoingInterceptor.onMessage(Message<?> message)	Deprecated. use OutgoingInterceptor.beforeMessageSend(Message)
void	IncomingInterceptor.onMessageAck(Message<?> message)	Called after message acknowledgment
void	OutgoingInterceptor.onMessageAck(Message<?> message)	Called after message acknowledgment
void	IncomingInterceptor.onMessageNack(Message<?> message, Throwable failure)	Called after message negative-acknowledgement
void	OutgoingInterceptor.onMessageNack(Message<?> message, Throwable failure)	Called after message negative-acknowledgement
static void	OutgoingMessageMetadata.setResultOnMessage(Message<?> message, Object result)
Message<T>	GenericPayload.toMessage(Message<?> message)	Converts this payload to a message, merging the metadata with the given message.
List<Message<?>>	Messages.MessageChainBuilder.with(Message<?>... messages)	Chain the passed array of messages.
TargetedMessages	TargetedMessages.Default.withMessage(String channel, Message<?> message)
TargetedMessages	TargetedMessages.withMessage(String channel, Message<?> message)	Add a new mapping to this target mapping.

Method parameters in io.smallrye.reactive.messaging with type arguments of type Message

Modifier and Type	Method	Description
default io.smallrye.mutiny.Multi<? extends Message<?>>	PublisherDecorator.decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, String channelName, boolean isConnector)	Deprecated. replaced with PublisherDecorator.decorate(Multi, List, boolean)
default io.smallrye.mutiny.Multi<? extends Message<?>>	PublisherDecorator.decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, List<String> channelName, boolean isConnector)	Decorate a Multi
io.smallrye.mutiny.Multi<? extends Message<?>>	SubscriberDecorator.decorate(io.smallrye.mutiny.Multi<? extends Message<?>> toBeSubscribed, List<String> channelName, boolean isConnector)	Decorate a Multi
static TargetedMessages	TargetedMessages.from(Map<String,Message<?>> entries)
static <T> Message<T>	Messages.merge(List<Message<?>> list, Function<List<?>,T> combinator)	Merges multiple messages into a single one.
static <T> Message<List<T>>	Messages.merge(List<Message<T>> list)	Merges multiple messages into a single one.
Flow.Publisher<? extends Message<?>>	ChannelRegistry.register(String name, Flow.Publisher<? extends Message<?>> stream, boolean broadcast)
Flow.Subscriber<? extends Message<?>>	ChannelRegistry.register(String name, Flow.Subscriber<? extends Message<?>> subscriber, boolean merge)
TargetedMessages	Messages.MessageChainBuilder.with(Map<String,Message<?>> messages)	Chain the passed map of messages.

Constructor parameters in io.smallrye.reactive.messaging with type arguments of type Message

Modifier	Constructor	Description
	Default(Map<String,Message<?>> map)

Uses of Message in io.smallrye.reactive.messaging.connector

Methods in io.smallrye.reactive.messaging.connector that return types with arguments of type Message

Modifier and Type	Method	Description
Flow.Publisher<? extends Message<?>>	InboundConnector.getPublisher(Config config)	Creates a channel for the given configuration.
Flow.Subscriber<? extends Message<?>>	OutboundConnector.getSubscriber(Config config)	Creates a channel for the given configuration.

Uses of Message in io.smallrye.reactive.messaging.kafka.api

Methods in io.smallrye.reactive.messaging.kafka.api that return Message

Modifier and Type	Method	Description
static <T, K> Message<T>	KafkaMetadataUtil.writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata)	Write OutgoingKafkaRecordMetadata to a Message.

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

Modifier and Type	Method	Description
static Optional<IncomingKafkaRecordMetadata>	KafkaMetadataUtil.readIncomingKafkaMetadata(Message<?> msg)	Read IncomingKafkaRecordMetadata from a Message.
static <T, K> Message<T>	KafkaMetadataUtil.writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata)	Write OutgoingKafkaRecordMetadata to a Message.

Uses of Message in io.smallrye.reactive.messaging.keyed

Methods in io.smallrye.reactive.messaging.keyed with parameters of type Message

Modifier and Type	Method	Description
boolean	KeyValueExtractor.canExtract(Message<?> first, Type keyType, Type valueType)	Checks if the current extractor can handle the given method to extract a key of type keyType and a value of type valueType.
Object	KeyValueExtractor.extractKey(Message<?> message, Type keyType)	Extracts the key from the given message.
Object	KeyValueExtractor.extractValue(Message<?> message, Type valueType)	Extracts the value from the given message.

Uses of Message in io.smallrye.reactive.messaging.observation

Methods in io.smallrye.reactive.messaging.observation with parameters of type Message

Modifier and Type	Method	Description
void	DefaultMessageObservation.onMessageAck(Message<?> message)
void	MessageObservation.onMessageAck(Message<?> message)	Notify the observation of acknowledgement event
void	DefaultMessageObservation.onMessageNack(Message<?> message, Throwable reason)
void	MessageObservation.onMessageNack(Message<?> message, Throwable reason)	Notify the observation of negative acknowledgement event
MessageObservation	MessageObservationCollector.onNewMessage(String channel, Message<?> message, T observationContext)	Returns a new MessageObservation object on which to collect the message processing events.

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

Methods in org.eclipse.microprofile.reactive.messaging with type parameters of type Message

Modifier and Type	Method	Description
<M extends Message<? extends T>> void	Emitter.send(M msg)	Sends a message to the channel.

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

Modifier and Type	Method	Description
default Message<T>	Message.addMetadata(Object metadata)	Creates a new instance of Message with the current metadata, plus the given one.
static <T> Message<T>	Message.of(T payload)	Create a message with the given payload.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata)	Create a message with the given payload and metadata.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata, Function<Metadata,CompletionStage<Void>> ackM)	Create a message with the given payload, metadata and ack function.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata, Function<Metadata,CompletionStage<Void>> ackM, BiFunction<Throwable,Metadata,CompletionStage<Void>> nackM)	Create a message with the given payload, metadata and ack and nack functions.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata, Supplier<CompletionStage<Void>> ack)	Create a message with the given payload, metadata and ack function.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack)	Create a message with the given payload, metadata and ack and nack functions.
static <T> Message<T>	Message.of(T payload, Function<Metadata,CompletionStage<Void>> ackM)	Create a message with the given payload and ack function.
static <T> Message<T>	Message.of(T payload, Function<Metadata,CompletionStage<Void>> ack, BiFunction<Throwable,Metadata,CompletionStage<Void>> nack)
static <T> Message<T>	Message.of(T payload, Supplier<CompletionStage<Void>> ack)	Create a message with the given payload and ack function.
static <T> Message<T>	Message.of(T payload, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack)	Create a message with the given payload, ack and nack functions.
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, Function<Metadata,CompletionStage<Void>> ackM, BiFunction<Throwable,Metadata,CompletionStage<Void>> nackM)	Create a message with the given payload, metadata and ack and nack functions.
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 <R> Message<R>	Message.thenApply(Function<Message<T>,Message<R>> modifier)	Apply the given modifier function to the current message returning the result for further composition
default Message<T>	Message.withAck(Supplier<CompletionStage<Void>> supplier)	Creates a new instance of Message with the given acknowledgement supplier.
default Message<T>	Message.withAckWithMetadata(Function<Metadata,CompletionStage<Void>> supplier)	Creates a new instance of Message with the given acknowledgement supplier.
default Message<T>	Message.withMetadata(Iterable<Object> metadata)	Creates a new instance of Message with the specified metadata.
default Message<T>	Message.withMetadata(Metadata metadata)	Creates a new instance of Message with the specified metadata.
default Message<T>	Message.withNack(Function<Throwable,CompletionStage<Void>> nack)	Creates a new instance of Message with the given negative-acknowledgement function.
default Message<T>	Message.withNackWithMetadata(BiFunction<Throwable,Metadata,CompletionStage<Void>> nack)	Creates a new instance of Message with the given negative-acknowledgement function.
default <P> Message<P>	Message.withPayload(P payload)	Creates a new instance of Message with the specified payload.

Method parameters in org.eclipse.microprofile.reactive.messaging with type arguments of type Message

Modifier and Type	Method	Description
default <R> Message<R>	Message.thenApply(Function<Message<T>,Message<R>> modifier)	Apply the given modifier function to the current message returning the result for further composition
default <R> Message<R>	Message.thenApply(Function<Message<T>,Message<R>> modifier)	Apply the given modifier function to the current message returning the result for further composition

Uses of Message in org.eclipse.microprofile.reactive.messaging.spi

Methods in org.eclipse.microprofile.reactive.messaging.spi that return types with arguments of type Message

Modifier and Type	Method	Description
PublisherBuilder<? extends Message<?>>	IncomingConnectorFactory.getPublisherBuilder(Config config)	Creates a channel for the given configuration.
SubscriberBuilder<? extends Message<?>,Void>	OutgoingConnectorFactory.getSubscriberBuilder(Config config)	Creates a channel for the given configuration.