Package io.axoniq.framework.axonserver.connector.event

Class DefaultPersistentStreamEventSourceFactory

java.lang.Object

io.axoniq.framework.axonserver.connector.event.DefaultPersistentStreamEventSourceFactory

All Implemented Interfaces:

PersistentStreamEventSourceFactory

public class DefaultPersistentStreamEventSourceFactory
extends Object
implements PersistentStreamEventSourceFactory

Default implementation of PersistentStreamEventSourceFactory.

Tracks all stream names that have been used to create a PersistentStreamEventSource and logs a warning when the same Axon Server stream name is used more than once. Two sources sharing the same server-side stream name will join the same stream, which is typically a misconfiguration.

Since:

5.2.0

Author:

Jakob Hatzl

See Also:

• PersistentStreamEventSourceFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final PersistentStreamEventSourceFactory	INSTANCE	Default singleton instance for the DefaultPersistentStreamEventSourceFactory.

Constructor Summary

Constructors

Constructor	Description
DefaultPersistentStreamEventSourceFactory()

Method Summary

Modifier and Type	Method	Description
PersistentStreamEventSource	build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties properties, ScheduledExecutorService scheduler, int batchSize, Configuration configuration)	Builds a PersistentStreamEventSource for the given stream parameters.

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final PersistentStreamEventSourceFactory INSTANCE

Default singleton instance for the DefaultPersistentStreamEventSourceFactory. Use this to ensure stream name duplication warnings across all streams constructed with this.

Constructor Details

DefaultPersistentStreamEventSourceFactory

public DefaultPersistentStreamEventSourceFactory()

Method Details

build

public PersistentStreamEventSource build(String name,
 io.axoniq.axonserver.connector.event.PersistentStreamProperties properties,
 ScheduledExecutorService scheduler,
 int batchSize,
 Configuration configuration)

Description copied from interface: PersistentStreamEventSourceFactory

Builds a PersistentStreamEventSource for the given stream parameters.

The supplied Configuration provides access to all registered framework components, such as the AxonServerConnectionManager and EventConverter, so implementations do not need to receive those as constructor arguments.

Specified by:

build in interface PersistentStreamEventSourceFactory

Parameters:

name - the unique stream name on Axon Server

properties - the persistent stream properties (segment count, sequencing policy, filter, etc.)

scheduler - the scheduled executor to use for this stream's background tasks

batchSize - the maximum number of events to deliver per batch

configuration - the framework configuration from which additional components can be retrieved

Returns:

a new PersistentStreamEventSource