org.axonframework.axonserver.connector.event.axon

Class PersistentStreamConnection

java.lang.Object

org.axonframework.axonserver.connector.event.axon.PersistentStreamConnection

public class PersistentStreamConnection
extends Object

A connection instance receiving the events for a persistent stream to pass on in batches of events to an event consumer.

Since:

4.10.0

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
PersistentStreamConnection(String streamId, Configuration configuration, io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties, ScheduledExecutorService scheduler, int batchSize) Instantiates a connection for a persistent stream.
PersistentStreamConnection(String streamId, Configuration configuration, io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties, ScheduledExecutorService scheduler, int batchSize, String defaultContext) Instantiates a connection for a persistent stream.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the persistent stream connection to Axon Server.
void	open(Consumer<List<? extends EventMessage<?>>> consumer) Initiates the connection to Axon Server to read events from the persistent stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentStreamConnection

public PersistentStreamConnection(String streamId,
                                  Configuration configuration,
                                  io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
                                  ScheduledExecutorService scheduler,
                                  int batchSize)

Instantiates a connection for a persistent stream.

Parameters:

streamId - The identifier of the persistent stream.

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.

PersistentStreamConnection

public PersistentStreamConnection(String streamId,
                                  Configuration configuration,
                                  io.axoniq.axonserver.connector.event.PersistentStreamProperties persistentStreamProperties,
                                  ScheduledExecutorService scheduler,
                                  int batchSize,
                                  String defaultContext)

Instantiates a connection for a persistent stream.

Parameters:

streamId - The identifier of the persistent stream.

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.

defaultContext - The default context to use for the connection.

Method Detail

open

public void open(Consumer<List<? extends EventMessage<?>>> consumer)

Initiates the connection to Axon Server to read events from the persistent stream.

Parameters:

consumer - The consumer of batches of event messages.

close

public void close()

Closes the persistent stream connection to Axon Server.