Package org.axonframework.axonserver.connector.event.axon

Class DefaultPersistentStreamMessageSourceFactory

java.lang.Object

org.axonframework.axonserver.connector.event.axon.DefaultPersistentStreamMessageSourceFactory

All Implemented Interfaces:

PersistentStreamMessageSourceFactory

public class DefaultPersistentStreamMessageSourceFactory
extends Object
implements PersistentStreamMessageSourceFactory

Default implementation of the PersistentStreamMessageSourceFactory that creates PersistentStreamMessageSource instances. Maintains a record of used stream names and provides warning logs when name conflicts occur.

Since:

4.11

Author:

Mateusz Nowak

Constructor Summary

Constructors

Constructor	Description
DefaultPersistentStreamMessageSourceFactory()

Method Summary

Modifier and Type	Method	Description
PersistentStreamMessageSource	build(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties, ScheduledExecutorService scheduler, int batchSize, String context, Configuration configuration)	Creates a new PersistentStreamMessageSource.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultPersistentStreamMessageSourceFactory

public DefaultPersistentStreamMessageSourceFactory()

Method Details

build

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

Creates a new PersistentStreamMessageSource. This method tracks stream names and logs warnings when name conflicts are detected.

Specified by:

build in interface PersistentStreamMessageSourceFactory

Parameters:

name - The name of the persistent stream. It's a unique identifier of the PersistentStream connection with Axon Sever. Usage of the same name will overwrite the existing connection.

persistentStreamProperties - The properties to create te persistent stream.

scheduler - Scheduler used for persistent stream operations.

batchSize - The batch size for collecting events.

context - The context in which this persistent stream exists (or needs to be created).

configuration - Global configuration of Axon components.

Returns:

A new PersistentStreamMessageSource instance.