org.axonframework.messaging

Interface MessageStream<M extends Message<?>>

Type Parameters:

M - the type of Message contained in this stream

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

TrackingEventStream

All Known Implementing Classes:

KafkaMessageStream

public interface MessageStream<M extends Message<?>>
extends AutoCloseable

Interface for a tracked stream of Messages.

Author:

Rene de Waele

Method Summary

Modifier and Type	Method and Description
default Stream<M>	asStream() Returns this MessageStream as a Stream of Messages.
void	close()
default boolean	hasNextAvailable() Checks whether or not the next message in the stream is available.
boolean	hasNextAvailable(int timeout, TimeUnit unit) Checks whether or not the next message in the stream is available.
M	nextAvailable() Returns the next available message in the stream.
Optional<M>	peek() Checks whether or not the next message in the stream is immediately available.

Method Detail

hasNextAvailable

default boolean hasNextAvailable()

Checks whether or not the next message in the stream is available. If so this method returns true immediately. If not it returns false immediately.

Returns:

true if a message is available or becomes available before the given timeout, false otherwise

peek

Optional<M> peek()

Checks whether or not the next message in the stream is immediately available. If so, an Optional with the next message is returned (without moving the stream pointer), otherwise an empty Optional is returned.

Returns:

the next event if immediately available

hasNextAvailable

boolean hasNextAvailable(int timeout,
                         TimeUnit unit)
                  throws InterruptedException

Checks whether or not the next message in the stream is available. If a message is available when this method is invoked this method returns immediately. If not, this method will block until a message becomes available, returning true or until the given timeout expires, returning false.

To check if the stream has messages available now, pass a zero timeout.

Parameters:

timeout - the maximum number of time units to wait for messages to become available

unit - the time unit for the timeout

Returns:

true if a message is available or becomes available before the given timeout, false otherwise

Throws:

InterruptedException - when the thread is interrupted before the indicated time is up

nextAvailable

M nextAvailable()
         throws InterruptedException

Returns the next available message in the stream. Note that this method blocks for as long as there are no available messages in the stream. In case this blocking behavior is not desired use hasNextAvailable() with or without a timeout to check if the stream has available messages before calling this method.

Returns:

the next available message

Throws:

InterruptedException - when the thread is interrupted before the next message is returned

close

void close()

Specified by:

close in interface AutoCloseable

asStream

default Stream<M> asStream()

Returns this MessageStream as a Stream of Messages. Note that the returned Stream will start at the current position of this instance.

Note that iterating over the returned Stream may affect this MessageStream and vice versa. It is therefore not recommended to use this MessageStream after invoking this method.

Returns:

This MessageStream as a Stream of Messages