org.axonframework.messaging

Interface StreamableMessageSource<M extends Message<?>>

All Known Subinterfaces:

EventBus, EventStore

All Known Implementing Classes:

AbstractEventBus, AbstractEventStore, EmbeddedEventStore, SimpleEventBus

public interface StreamableMessageSource<M extends Message<?>>

Interface for a source of messages that processors can track.

Author:

Rene de Waele

Method Summary

Modifier and Type	Method and Description
MessageStream<M>	openStream(TrackingToken trackingToken) Open a stream containing all messages since given tracking token.

Method Detail

openStream

MessageStream<M> openStream(TrackingToken trackingToken)

Open a stream containing all messages since given tracking token. Pass a trackingToken of null to open a stream containing all available messages. Note that the returned stream is infinite, so beware of applying terminal operations to the returned stream.

Parameters:

trackingToken - object containing the position in the stream or null to open a stream containing all messages

Returns:

a stream of messages since the given trackingToken