org.axonframework.axonserver.connector.event.axon

Class PersistentStreamMessageSourceDefinition

java.lang.Object

org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSourceDefinition

All Implemented Interfaces:

SubscribableMessageSourceDefinition<EventMessage<?>>

public class PersistentStreamMessageSourceDefinition
extends Object
implements SubscribableMessageSourceDefinition<EventMessage<?>>

Definition of a PersistentStreamMessageSource.

Used to create PersistentStreamMessageSource instances with a specific Axon configuration.

Since:

4.10.0

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
PersistentStreamMessageSourceDefinition(String name, io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties, ScheduledExecutorService scheduler, int batchSize, String context, PersistentStreamMessageSourceFactory messageSourceFactory) Instantiates a PersistentStreamMessageSourceDefinition instance based on the given parameters.

Method Summary

Modifier and Type	Method and Description
SubscribableMessageSource<EventMessage<?>>	create(Configuration configuration) Creates a SubscribableMessageSource based on this definition and the provided configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentStreamMessageSourceDefinition

public PersistentStreamMessageSourceDefinition(String name,
                                               io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
                                               ScheduledExecutorService scheduler,
                                               int batchSize,
                                               String context,
                                               PersistentStreamMessageSourceFactory messageSourceFactory)

Instantiates a PersistentStreamMessageSourceDefinition instance based on the given parameters.

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).

Method Detail

create

public SubscribableMessageSource<EventMessage<?>> create(Configuration configuration)

Description copied from interface: SubscribableMessageSourceDefinition

Creates a SubscribableMessageSource based on this definition and the provided configuration.

Specified by:

create in interface SubscribableMessageSourceDefinition<EventMessage<?>>

Parameters:

configuration - The Axon Configuration to base the SubscribableMessageSource on.

Returns:

A SubscribableMessageSource based on this definition and the provided configuration.