org.axonframework.eventsourcing

Class MultiStreamableMessageSource

java.lang.Object

org.axonframework.eventhandling.MultiStreamableMessageSource

org.axonframework.eventsourcing.MultiStreamableMessageSource

All Implemented Interfaces:

StreamableMessageSource<TrackedEventMessage<?>>

Deprecated.

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

@Deprecated
public class MultiStreamableMessageSource
extends MultiStreamableMessageSource

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 and Description
static class	MultiStreamableMessageSource.Builder Deprecated. In favor of MultiStreamableMessageSource.Builder. This class belongs in the messaging module instead of the eventsourcing module.

Constructor Summary

Constructors

Modifier	Constructor and Description
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.

Method Summary

Modifier and Type	Method and Description
static MultiStreamableMessageSource.Builder	builder() Deprecated. In favor of MultiStreamableMessageSource.builder(). This class belongs in the messaging module instead of the eventsourcing module.

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 Detail

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 Detail

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.