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

Packages that use MessageStream.Entry

Package	Description
org.axonframework.axonserver.connector.event	Part of the Axon Server Connector module.
org.axonframework.axonserver.connector.query	Part of the Axon Server Connector module.
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.deadletter.jpa	Part of the Axon Messaging module.
org.axonframework.messaging.eventstreaming	Part of the Axon Messaging module.

Uses of MessageStream.Entry in org.axonframework.axonserver.connector.event

Methods in org.axonframework.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 org.axonframework.axonserver.connector.query

Methods in org.axonframework.axonserver.connector.query that return types with arguments of type MessageStream.Entry

Modifier and Type	Method	Description
Optional<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.next()
Optional<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.peek()

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
Optional<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.next()
Optional<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.peek()

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 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 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<MessageStream.Entry<M>>	MessageStream.Single.asCompletableFuture()	Returns a CompletableFuture that completes with the first entry contained in this MessageStream, or exceptionally if the stream completes with an error before returning any entries.
static <M extends Message> CompletableFuture<MessageStream.Entry<M>>	MessageStreamUtils.asCompletableFuture(MessageStream<M> source)	Returns a CompletableFuture that completes with the first entry from the given source.
Optional<MessageStream.Entry<M>>	CloseCallbackMessageStream.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.
Optional<MessageStream.Entry<M>>	QueueMessageStream.next()
static <M extends Message> reactor.core.publisher.Flux<MessageStream.Entry<M>>	FluxUtils.of(MessageStream<M> source)	Creates a Flux containing the entries provided by the given source.
Optional<MessageStream.Entry<M>>	CloseCallbackMessageStream.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.
Optional<MessageStream.Entry<M>>	QueueMessageStream.peek()

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)
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,MessageStream.Entry<M>,R> accumulator)
default <R> CompletableFuture<R>	MessageStream.reduce(R identity, BiFunction<R,MessageStream.Entry<M>,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<R>	MessageStreamUtils.reduce(MessageStream<M> source, R identity, BiFunction<R,MessageStream.Entry<M>,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)	Construct an instance with given queue as the underlying queue.

Uses of MessageStream.Entry in org.axonframework.messaging.eventhandling.deadletter.jpa

Methods in org.axonframework.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 org.axonframework.messaging.eventstreaming

Method parameters in org.axonframework.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 org.axonframework.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.