Uses of Interface
org.axonframework.messaging.core.MessageStream.Entry

Packages that use MessageStream.Entry

Package	Description
io.axoniq.framework.axonserver.connector.event	Part of the Axon Server Connector module.
io.axoniq.framework.axonserver.connector.query	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.eventhandling.deadletter.jpa	Part of the Axon Messaging module.
io.axoniq.framework.messaging.eventstreaming	Part of the Axoniq Messaging folder.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.eventhandling.processing	Part of the Axon Messaging module.

Uses of MessageStream.Entry in io.axoniq.framework.axonserver.connector.event

Methods in io.axoniq.framework.axonserver.connector.event that return types with arguments of type MessageStream.Entry

Modifier and Type	Method	Description
Optional<MessageStream.Entry<EventMessage>>	SourcingEventMessageStream.next()
Optional<MessageStream.Entry<EventMessage>>	StreamingEventMessageStream.next()
Optional<MessageStream.Entry<EventMessage>>	SourcingEventMessageStream.peek()
Optional<MessageStream.Entry<EventMessage>>	StreamingEventMessageStream.peek()

Uses of MessageStream.Entry in io.axoniq.framework.axonserver.connector.query

Methods in io.axoniq.framework.axonserver.connector.query that return types with arguments of type MessageStream.Entry

Modifier and Type	Method	Description
protected AbstractMessageStream.FetchResult<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.fetchNext()

Uses of MessageStream.Entry in io.axoniq.framework.messaging.eventhandling.deadletter.jpa

Methods in io.axoniq.framework.messaging.eventhandling.deadletter.jpa that return MessageStream.Entry

Modifier and Type	Method	Description
MessageStream.Entry<M>	DeadLetterJpaConverter.convert(DeadLetterEventEntry entry, EventConverter eventConverter, Converter genericConverter)	Converts a DeadLetterEventEntry to a MessageStream.Entry containing the EventMessage implementation and a Context with restored resources.
MessageStream.Entry<EventMessage>	EventMessageDeadLetterJpaConverter.convert(DeadLetterEventEntry entry, EventConverter eventConverter, Converter genericConverter)

Uses of MessageStream.Entry in io.axoniq.framework.messaging.eventstreaming

Method parameters in io.axoniq.framework.messaging.eventstreaming with type arguments of type MessageStream.Entry

Modifier and Type	Method	Description
MultiStreamableEventSource	MultiStreamableEventSource.SourceCollector.comparingUsing(Comparator<MessageStream.Entry<EventMessage>> comparator)	Creates a MultiStreamableEventSource using a custom comparator.

Constructor parameters in io.axoniq.framework.messaging.eventstreaming with type arguments of type MessageStream.Entry

Modifier	Constructor	Description
protected	MultiStreamableEventSource(Map<String,StreamableEventSource> eventSources, Comparator<MessageStream.Entry<EventMessage>> eventComparator)	Constructs a MultiStreamableEventSource from the collected sources and comparator.

Uses of MessageStream.Entry in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore that return types with arguments of type MessageStream.Entry

Modifier and Type	Method	Description
protected AbstractMessageStream.FetchResult<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.fetchNext()

Constructor parameters in org.axonframework.eventsourcing.eventstore with type arguments of type MessageStream.Entry

Modifier	Constructor	Description
	ContinuousMessageStream(Supplier<List<E>> fetcher, Function<E,MessageStream.Entry<EventMessage>> converter, BiFunction<ContinuousMessageStream<?>,Runnable,Registration> callbackTracker)	Creates a new ContinuousMessageStream instance configured with the given strategies.

Uses of MessageStream.Entry in org.axonframework.messaging.core

Classes in org.axonframework.messaging.core with type parameters of type MessageStream.Entry

Modifier and Type	Interface	Description
static interface	AbstractMessageStream.FetchResult<T extends @Nullable MessageStream.Entry<?>>	Represents the result of attempting to fetch the next element from a MessageStream.
static final record	AbstractMessageStream.FetchResult.Completed<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult indicating that the stream is exhausted and no further elements will be produced.
static final record	AbstractMessageStream.FetchResult.Error<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult representing a terminal error in the stream.
static final record	AbstractMessageStream.FetchResult.NotReady<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult indicating that no element is currently available, but the stream may produce more elements in the future.
static final record	AbstractMessageStream.FetchResult.Value<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult containing a successfully fetched value.

Classes in org.axonframework.messaging.core that implement MessageStream.Entry

Modifier and Type	Class	Description
final record	SimpleEntry<M extends Message>	Simple implementation of the MessageStream.Entry containing a single Message implementation of type M and a Context.

Methods in org.axonframework.messaging.core with type parameters of type MessageStream.Entry

Modifier and Type	Method	Description
static <T extends MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.completed()	Returns a FetchResult indicating that no element is available and no further elements will be produced.
static <T extends MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.error(Throwable error)	Creates a FetchResult representing a producer side error.
static <T extends MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.notReady()	Returns a FetchResult indicating that no element is currently available, but more elements may become available in the future.
static <T extends @Nullable MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.of(@Nullable T value)	Creates a FetchResult representing a successfully fetched value.

Methods in org.axonframework.messaging.core that return MessageStream.Entry

Modifier and Type	Method	Description
<RM extends Message> MessageStream.Entry<RM>	MessageStream.Entry.map(Function<M,RM> mapper)	Maps the message() by running it through the given mapper.
<RM extends Message> MessageStream.Entry<RM>	SimpleEntry.map(Function<M,RM> mapper)
<T> MessageStream.Entry<M>	MessageStream.Entry.withResource(Context.ResourceKey<T> key, T resource)
<T> MessageStream.Entry<M>	SimpleEntry.withResource(Context.ResourceKey<T> key, T resource)

Methods in org.axonframework.messaging.core that return types with arguments of type MessageStream.Entry

Modifier and Type	Method	Description
default CompletableFuture<@Nullable MessageStream.Entry<M>>	MessageStream.Single.asCompletableFuture()	Returns a CompletableFuture that completes when this stream has been fully consumed, either normally or with an error.
protected abstract AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	AbstractMessageStream.fetchNext()	Attempts to fetch the next available MessageStream.Entry from the underlying source.
protected AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	CloseCallbackMessageStream.fetchNext()
protected AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	QueueMessageStream.fetchNext()
final Optional<MessageStream.Entry<M>>	AbstractMessageStream.next()
Optional<MessageStream.Entry<M>>	DelayedMessageStream.next()
Optional<MessageStream.Entry<M>>	MergedMessageStream.next()
Optional<MessageStream.Entry<M>>	MessageStream.next()	Returns an Optional carrying the next entry from the stream, if such entry was available.
static <M extends Message> AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	AbstractMessageStream.FetchResult.of(MessageStream<M> delegate)	Creates a FetchResult reflecting the current observable state of the given MessageStream.
static <M extends Message> reactor.core.publisher.Flux<MessageStream.Entry<M>>	FluxUtils.of(MessageStream<? extends M> source)	Creates a Flux containing the entries provided by the given source.
final Optional<MessageStream.Entry<M>>	AbstractMessageStream.peek()
Optional<MessageStream.Entry<M>>	DelayedMessageStream.peek()
Optional<MessageStream.Entry<M>>	MergedMessageStream.peek()
Optional<MessageStream.Entry<M>>	MessageStream.peek()	Returns an Optional carrying the next entry from the stream (without moving the stream pointer), if such entry was available.

Method parameters in org.axonframework.messaging.core with type arguments of type MessageStream.Entry

Modifier and Type	Method	Description
default MessageStream<M>	MessageStream.filter(Predicate<MessageStream.Entry<M>> filter)	Returns a stream that will filter entries based on the given filter.
default MessageStream.Single<M>	MessageStream.Single.filter(Predicate<MessageStream.Entry<M>> filter)
protected final void	AbstractMessageStream.initialize(AbstractMessageStream.FetchResult<MessageStream.Entry<M>> initialFetchResult)	This method can be used after the super constructor call completes in a subtype to set the initial state of the stream.
default <RM extends Message> MessageStream.Empty<RM>	MessageStream.Empty.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
default <RM extends Message> MessageStream.Empty<RM>	MessageStream.Empty.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
default <RM extends Message> MessageStream<RM>	MessageStream.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)	Returns a stream that maps each entry from this stream using given mapper function into an entry carrying a MessageEntry with a Message of type RM.
default <RM extends Message> MessageStream<RM>	MessageStream.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)	Returns a stream that maps each entry from this stream using given mapper function into an entry carrying a MessageEntry with a Message of type RM.
default <RM extends Message> MessageStream.Single<RM>	MessageStream.Single.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
default <RM extends Message> MessageStream.Single<RM>	MessageStream.Single.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
default MessageStream.Empty<M>	MessageStream.Empty.onNext(Consumer<MessageStream.Entry<M>> onNext)
default MessageStream<M>	MessageStream.onNext(Consumer<MessageStream.Entry<M>> onNext)	Invokes the given onNext each time an entry is consumed from this stream.
default MessageStream.Single<M>	MessageStream.Single.onNext(Consumer<MessageStream.Entry<M>> onNext)
<R> CompletableFuture<R>	DelayedMessageStream.reduce(R identity, BiFunction<R,? super MessageStream.Entry<M>,R> accumulator)
default <R> CompletableFuture<@Nullable R>	MessageStream.reduce(@Nullable R identity, BiFunction<@Nullable R,? super MessageStream.Entry<M>,@Nullable R> accumulator)	Returns a CompletableFuture of type R, using the given identity as the initial value for the given accumulator.
static <M extends Message, R> CompletableFuture<@Nullable R>	MessageStreamUtils.reduce(MessageStream<M> source, @Nullable R identity, BiFunction<@Nullable R,? super MessageStream.Entry<M>,@Nullable R> accumulator)	Returns a CompletableFuture that completes with the given reduction of messages read from the source.

Constructor parameters in org.axonframework.messaging.core with type arguments of type MessageStream.Entry

Modifier	Constructor	Description
	MergedMessageStream(Comparator<MessageStream.Entry<M>> comparator, MessageStream<M> first, MessageStream<M> second)	Constructs a MergedMessageStream that merges two message streams based on the given comparator.
	QueueMessageStream(BlockingQueue<MessageStream.Entry<M>> queue)	Constructs a QueueMessageStream using the given queue as its underlying buffer.

Uses of MessageStream.Entry in org.axonframework.messaging.eventhandling.processing

Method parameters in org.axonframework.messaging.eventhandling.processing with type arguments of type MessageStream.Entry

Modifier and Type	Method	Description
MessageStream.Empty<Message>	ProcessorEventHandlingComponents.handle(List<MessageStream.Entry<? extends EventMessage>> entries, ProcessingContext context)	Processes a batch of events in the given processing context.