Uses of Class
io.helidon.messaging.MessageBatch

Packages that use MessageBatch

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 MessageBatch in io.helidon.messaging

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

Modifier and Type	Class	Description
static class	MessageBatchConfig.Builder<T>	Fluent API builder for MessageBatch.

Methods in io.helidon.messaging that return MessageBatch

Modifier and Type	Method	Description
MessageBatch<?>	BatchDeliveryException.batch()	Original batch.
MessageBatch<T>	MessageBatchConfig.Builder.build()	Create an instance from this builder.
static <T> MessageBatch<T>	MessageBatch.create(Message<? extends T> message)	Create an immutable singleton batch.
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.
MessageBatch<?>	ProcessorRegistration.process(MessageBatch<?> batch)	Invoke the processor adapter for one delivery and return one derived batch for ProcessorRegistration.outgoingChannel().
MessageBatch<T>	MessageBatch.subset(List<Integer> indexes)	Create an ordered retry or routing subset while preserving delivery identity and item lineage.

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

Modifier and Type	Method	Description
void	ConsumerRegistration.dispatch(MessageBatch<?> batch)	Dispatch one immutable delivery batch to the generated invocation adapter.
default void	ProcessorRegistration.dispatch(MessageBatch<?> batch)
void	Emitter.emit(MessageBatch<? extends T> batch)	Emit a batch of messages.
<T> void	MessagingRuntime.emitBatch(String channel, MessageBatch<? extends T> batch)	Emit a batch of messages to a named channel.
void	MessagingEntryPoint.BatchHandler.handle(T serviceInstance, MessageBatch<?> messages)	Invoke the handler once for the complete immutable batch.
MessageBatch<?>	ProcessorRegistration.process(MessageBatch<?> batch)	Invoke the processor adapter for one delivery and return one derived batch for ProcessorRegistration.outgoingChannel().
ConnectorDelivery	ConnectorDeliveryReservation.start(MessageBatch<?> batch)	Start a retained connector delivery, waiting for execution admission when necessary.
default ConnectorDelivery	ConnectorDeliveryReservation.startFailed(MessageBatch<?> batch, RuntimeException failure)	Start a retained connector delivery whose transport-to-message mapping failed before dispatch.
Optional<ConnectorDelivery>	ConnectorDeliveryReservation.tryStart(MessageBatch<?> batch)	Attempt to start a retained connector delivery without waiting.
default Optional<ConnectorDelivery>	ConnectorDeliveryReservation.tryStartFailed(MessageBatch<?> batch, RuntimeException failure)	Attempt to start a retained connector delivery with a pre-dispatch mapping failure without waiting.

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

Modifier and Type	Method	Description
<T> BUILDER	MessagingConfig.BuilderBase.batchSink(MessagingChannel<T> source, Consumer<MessageBatch<T>> sink)	Add a message batch sink.

Constructors in io.helidon.messaging with parameters of type MessageBatch

Modifier	Constructor	Description
	BatchDeliveryException(String message, Throwable cause, MessageBatch<?> batch, List<BatchItemOutcome> outcomes)	Create a structured batch failure.

Uses of MessageBatch in io.helidon.messaging.spi

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

Modifier and Type	Method	Description
void	OutgoingChannel.sendBatch(MessageBatch<?> batch)	Send a batch of messages to the connector target.