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

Class PersistentStreamMessageSource

java.lang.Object

org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSource

All Implemented Interfaces:

org.axonframework.messaging.SubscribableMessageSource<org.axonframework.eventhandling.EventMessage<?>>

public class PersistentStreamMessageSource
extends Object
implements org.axonframework.messaging.SubscribableMessageSource<org.axonframework.eventhandling.EventMessage<?>>

A SubscribableMessageSource that receives event from a persistent stream from Axon Server. The persistent stream is identified by a unique name, which serves as an identifier for the PersistentStream connection with Axon Server. Using the same name for different instances will overwrite the existing connection.

Since:

4.10.0

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor	Description
PersistentStreamMessageSource(String name, org.axonframework.config.Configuration configuration, io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties, ScheduledExecutorService scheduler, int batchSize)	Instantiates a PersistentStreamMessageSource.
PersistentStreamMessageSource(String name, org.axonframework.config.Configuration configuration, io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties, ScheduledExecutorService scheduler, int batchSize, String context)	Instantiates a PersistentStreamMessageSource.

Method Summary

Modifier and Type	Method	Description
org.axonframework.common.Registration	subscribe(Consumer<List<? extends org.axonframework.eventhandling.EventMessage<?>>> consumer)

Methods inherited from class java.lang.Object

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

Constructor Details

PersistentStreamMessageSource

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

Instantiates a PersistentStreamMessageSource.

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.

configuration - Global configuration of Axon components.

persistentStreamProperties - Properties for the persistent stream.

scheduler - Scheduler thread pool to schedule tasks.

batchSize - The batch size for collecting events.

PersistentStreamMessageSource

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

Instantiates a PersistentStreamMessageSource.

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.

configuration - Global configuration of Axon components.

persistentStreamProperties - Properties for the persistent stream.

scheduler - Scheduler thread pool to schedule tasks.

batchSize - The batch size for collecting events.

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

Method Details

subscribe

public org.axonframework.common.Registration subscribe(@Nonnull
 Consumer<List<? extends org.axonframework.eventhandling.EventMessage<?>>> consumer)

Specified by:

subscribe in interface org.axonframework.messaging.SubscribableMessageSource<org.axonframework.eventhandling.EventMessage<?>>