public static class AxonServerConfiguration.PersistentStreamSettings extends Object
Constructor and Description |
---|
PersistentStreamSettings() |
Modifier and Type | Method and Description |
---|---|
int |
getBatchSize()
The maximum number of events to process in a single transaction when reading a persistent stream.
|
String |
getFilter()
Expression to filter out events in a persistent stream.
|
String |
getInitialPosition()
The initial token position for the persistent stream.
|
int |
getInitialSegmentCount()
The number of segments for the persistent stream if it needs to be created.
|
String |
getName()
The name for the persistent stream.
|
String |
getSequencingPolicy()
The sequencing policy to use for the persistent stream.
|
List<String> |
getSequencingPolicyParameters()
Parameters specified for the sequencing policy.
|
void |
setBatchSize(int batchSize)
Sets the maximum number of events to process in a single transaction when reading a persistent stream.
|
void |
setFilter(String filter)
Sets the expression to filter out events in a persistent stream.
|
void |
setInitialPosition(String initialPosition)
Sets the initial token for the persistent stream.
|
void |
setInitialSegmentCount(int initialSegmentCount)
Sets the number of segments for the persistent stream if it needs to be created.
|
void |
setName(String name)
Assigns a name for the persistent stream.
|
void |
setSequencingPolicy(String sequencingPolicy)
Sets the sequencing policy to use for the persistent stream.
|
void |
setSequencingPolicyParameters(List<String> sequencingPolicyParameters)
Sets the parameters specified for the sequencing policy.
|
public int getInitialSegmentCount()
public void setInitialSegmentCount(int initialSegmentCount)
initialSegmentCount
- the number of segmentspublic String getSequencingPolicy()
public void setSequencingPolicy(String sequencingPolicy)
Supported sequencing policies are:
This value is only used for creating the persistent stream.
sequencingPolicy
- The sequencing policy name.public List<String> getSequencingPolicyParameters()
public void setSequencingPolicyParameters(List<String> sequencingPolicyParameters)
The PropertySequencingPolicy and MetaDataSequencingPolicy require parameters.
This value is only used for creating the persistent stream.
sequencingPolicyParameters
- A list of parameters specified for the sequencing policy.public String getFilter()
public void setFilter(String filter)
This value is only used for creating the persistent stream.
filter
- The filter expression.public String getName()
public void setName(String name)
This value is only used for creating the persistent stream.
name
- The given name for a persistent stream.public int getBatchSize()
public void setBatchSize(int batchSize)
batchSize
- The batch size.public String getInitialPosition()
"HEAD"
or "TAIL"
for a respective position at the head or tail of the stream.public void setInitialPosition(String initialPosition)
You can use values "HEAD"
or "TAIL"
to start from the head or tail of the event
stream.
This value is only used for creating the persistent stream.
initialPosition
- The initial token position.Copyright © 2010–2024. All rights reserved.