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

Packages that use MessageStream.Entry

Package	Description
org.axonframework.axonserver.connector.event
org.axonframework.axonserver.connector.query
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.

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()

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>>	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>>	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
	QueueMessageStream(BlockingQueue<MessageStream.Entry<M>> queue)	Construct an instance with given queue as the underlying queue.