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

Class PersistentStreamMessageSourceDefinition

java.lang.Object

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

All Implemented Interfaces:

org.axonframework.config.SubscribableMessageSourceDefinition<org.axonframework.eventhandling.EventMessage<?>>

public class PersistentStreamMessageSourceDefinition
extends Object
implements org.axonframework.config.SubscribableMessageSourceDefinition<org.axonframework.eventhandling.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	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	Description
org.axonframework.messaging.SubscribableMessageSource<org.axonframework.eventhandling.EventMessage<?>>	create(org.axonframework.config.Configuration configuration)

Methods inherited from class java.lang.Object

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

Constructor Details

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 Details

create

public org.axonframework.messaging.SubscribableMessageSource<org.axonframework.eventhandling.EventMessage<?>> create(org.axonframework.config.Configuration configuration)

Specified by:

create in interface org.axonframework.config.SubscribableMessageSourceDefinition<org.axonframework.eventhandling.EventMessage<?>>