Uses of Interface
io.helidon.messaging.Message

Packages that use Message

Package	Description
io.helidon.messaging	Helidon Messaging API and runtime.
io.helidon.messaging.spi	Service provider interfaces implemented or extended by messaging transport connectors.

Uses of Message in io.helidon.messaging

Subinterfaces of Message in io.helidon.messaging

Modifier and Type	Interface	Description
interface	DeadLetterMessage<T>	Immutable message routed to a logical dead-letter channel.

Classes in io.helidon.messaging that implement interfaces with type arguments of type Message

Modifier and Type	Class	Description
final class	MessageBatch<T>	Immutable ordered delivery batch.
static class	MessageConfig.Builder<T>	Fluent API builder for Message.

Methods in io.helidon.messaging that return Message

Modifier and Type	Method	Description
Message<T>	MessageConfig.Builder.build()	Create an instance from this builder.
static <T> Message<T>	Message.create(T entity)	Create a payload-only message.
Message<T>	MessageBatch.get(int index)	Message at an index.
Message<T>	DeadLetterMessage.originalMessage()	Original extendable message envelope.

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

Modifier and Type	Method	Description
Optional<Message<?>>	MessagingEntryPoint.Handler.handle(T serviceInstance, Message<?> message)	Invoke the handler for one incoming message.
Iterator<Message<T>>	MessageBatch.iterator()
List<Message<T>>	MessageBatch.messages()	Ordered immutable message snapshot.
List<Message<T>>	MessageBatchConfig.BuilderBase.messages()	Ordered messages.
List<Message<T>>	MessageBatchConfig.messages()	Ordered messages.

Methods in io.helidon.messaging with parameters of type Message

Modifier and Type	Method	Description
BUILDER	MessageBatchConfig.BuilderBase.add(Message<T> add)	Ordered messages.
static <T> DeadLetterMessage<T>	DeadLetterMessage.create(Message<T> originalMessage, String sourceChannel, int attempts, RuntimeException failure)	Create a dead-letter message.
static <T> MessageBatch<T>	MessageBatch.create(Message<? extends T> message)	Create an immutable singleton batch.
default void	Emitter.emit(Message<? extends T> message)	Emit a message with metadata.
default <T> void	MessagingRuntime.emit(String channel, Message<T> message)	Emit a message to a named channel.
Optional<Message<?>>	MessagingEntryPoint.Handler.handle(T serviceInstance, Message<?> message)	Invoke the handler for one incoming message.

Method parameters in io.helidon.messaging with type arguments of type Message

Modifier and Type	Method	Description
BUILDER	MessageBatchConfig.BuilderBase.addMessages(List<Message<T>> messages)	Ordered messages.
static <T> MessageBatch<T>	MessageBatch.create(List<? extends Message<? extends T>> messages)	Create an immutable batch by copying the supplied message list.
<R> MessageBatch<R>	MessageBatch.derive(List<? extends Message<? extends R>> derivedMessages)	Internal generated-code operation that creates a one-to-one transformed batch while preserving delivery identity and item lineage.
<I,O> BUILDER	MessagingConfig.BuilderBase.messageProcessor(MessagingChannel<I> source, MessagingChannel<O> target, Function<? super Message<I>, ? extends Message<? extends O>> processor)	Add a message processor.
<I,O> BUILDER	MessagingConfig.BuilderBase.messageProcessor(MessagingChannel<I> source, MessagingChannel<O> target, Function<? super Message<I>, ? extends Message<? extends O>> processor)	Add a message processor.
BUILDER	MessageBatchConfig.BuilderBase.messages(List<Message<T>> messages)	Ordered messages.
<T> BUILDER	MessagingConfig.BuilderBase.messageSink(MessagingChannel<T> source, Consumer<? super Message<T>> sink)	Add a message sink.
<T> BUILDER	MessagingConfig.BuilderBase.messageSource(MessagingChannel<T> channel, Stream<? extends Message<? extends T>> source)	Add a message stream source.

Uses of Message in io.helidon.messaging.spi

Methods in io.helidon.messaging.spi with parameters of type Message

Modifier and Type	Method	Description
default void	OutgoingChannel.send(Message<?> message)	Send a message to the connector target.