Package org.axonframework.eventsourcing

Class MultiStreamableMessageSource

java.lang.Object

org.axonframework.eventhandling.MultiStreamableMessageSource

org.axonframework.eventsourcing.MultiStreamableMessageSource

All Implemented Interfaces:

StreamableMessageSource<TrackedEventMessage<?>>

@Deprecated
public class MultiStreamableMessageSource
extends MultiStreamableMessageSource

Deprecated.

In favor of MultiStreamableMessageSource. This class belongs in the messaging module instead of the eventsourcing module.

Implementation which allows for tracking processors to process messages from an arbitrary number of sources. The order in which messages from each stream are consumed is configurable but defaults to the oldest message available (using the event's timestamp). When the stream is polled for a specified duration, each stream is called with MultiSourceBlockingStream#hasNextAvailable() except for the last stream configured by the MultiStreamableMessageSource.Builder.addMessageSource(String, StreamableMessageSource) or by explicit configuration using MultiStreamableMessageSource.Builder.longPollingSource(String). This stream long polls for a fraction of the specified duration before looping through the sources again repeating until the duration has been met. This ensures the highest chance of a consumable message being found.

Since:

4.2

Author:

Greg Woods

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MultiStreamableMessageSource.Builder	Deprecated. In favor of MultiStreamableMessageSource.Builder.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MultiStreamableMessageSource(MultiStreamableMessageSource.Builder builder)	Deprecated. In favor of MultiStreamableMessageSource(org.axonframework.eventhandling.MultiStreamableMessageSource.Builder).

Method Summary

Modifier and Type	Method	Description
static MultiStreamableMessageSource.Builder	builder()	Deprecated. In favor of MultiStreamableMessageSource.builder().

Methods inherited from class org.axonframework.eventhandling.MultiStreamableMessageSource

createHeadToken, createTailToken, createTokenAt, createTokenSince, openStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MultiStreamableMessageSource

@Deprecated
protected MultiStreamableMessageSource(MultiStreamableMessageSource.Builder builder)

Deprecated.

In favor of MultiStreamableMessageSource(org.axonframework.eventhandling.MultiStreamableMessageSource.Builder). This class belongs in the messaging module instead of the eventsourcing module.

Instantiate a MultiStreamableMessageSource based on the fields contained in the MultiStreamableMessageSource.Builder.

Parameters:

builder - the MultiStreamableMessageSource.Builder used to instantiate a MultiStreamableMessageSource instance.

Method Details

builder

@Deprecated
public static MultiStreamableMessageSource.Builder builder()

Deprecated.

In favor of MultiStreamableMessageSource.builder(). This class belongs in the messaging module instead of the eventsourcing module.

Instantiate a Builder to be able to create an MultiStreamableMessageSource. The configurable field trackedEventComparator, which decides which message to process first if there is a choice defaults to the oldest message available (using the event's timestamp).

Returns:

a Builder to be able to create a MultiStreamableMessageSource.