JpaEventStorageEngine.Builder (Axon Framework 4.10.2 API)

java.lang.Object
- org.axonframework.eventsourcing.eventstore.AbstractEventStorageEngine.Builder
- - org.axonframework.eventsourcing.eventstore.BatchingEventStorageEngine.Builder
  - - org.axonframework.eventsourcing.eventstore.jpa.JpaEventStorageEngine.Builder

Enclosing class:

JpaEventStorageEngine
```
public static class JpaEventStorageEngine.Builder
extends BatchingEventStorageEngine.Builder
```
Builder class to instantiate a JpaEventStorageEngine.
The following configurable fields have defaults:
- The EventUpcaster defaults to an NoOpEventUpcaster.
- The PersistenceExceptionResolver is defaulted to a SQLErrorCodesResolver, if the DataSource is provided
- The snapshotFilter defaults to a SnapshotFilter.allowAll() instance.
- The batchSize defaults to an integer of size 100.
- The explicitFlush defaults to true.
- The maxGapOffset defaults to an integer of size 10000.
- The lowestGlobalSequence defaults to a long of size 1.
- The gapTimeout defaults to an integer of size 60000 (1 minute).
- The gapCleaningThreshold defaults to an integer of size 250.
The event and snapshot Serializer, the EntityManagerProvider and TransactionManager are hard requirements and as such should be provided.

Field Summary
- Fields inherited from class org.axonframework.eventsourcing.eventstore.AbstractEventStorageEngine.Builder
  upcasterChain

Constructor Summary

Constructors
Constructor and Description

Builder()

Constructors
Constructor and Description
`Builder()`

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`JpaEventStorageEngine.Builder`	`batchSize(int batchSize)` Sets the `batchSize` specifying the number of events that should be read at each database access.
`JpaEventStorageEngine`	`build()` Initializes a `JpaEventStorageEngine` as specified through this Builder.
`JpaEventStorageEngine.Builder`	`dataSource(DataSource dataSource)` Sets the `PersistenceExceptionResolver` as a `SQLErrorCodesResolver`, using the provided `DataSource` to resolve the error codes.
`JpaEventStorageEngine.Builder`	`entityManagerProvider(EntityManagerProvider entityManagerProvider)` Sets the `EntityManagerProvider` which provides the `EntityManager` used to access the underlying database for this `EventStorageEngine` implementation.
`JpaEventStorageEngine.Builder`	`eventSerializer(Serializer eventSerializer)` Sets the `Serializer` used to serialize and deserialize the Event Message's payload and `MetaData` with.
`JpaEventStorageEngine.Builder`	`explicitFlush(boolean explicitFlush)` Sets the `explicitFlush` field specifying whether to explicitly call `EntityManager.flush()` after inserting the Events published in this Unit of Work.
`JpaEventStorageEngine.Builder`	`finalAggregateBatchPredicate(Predicate<List<? extends DomainEventData<?>>> finalAggregateBatchPredicate)` Defines the predicate to use to recognize the terminal batch when reading an event stream for an aggregate.
`JpaEventStorageEngine.Builder`	`gapCleaningThreshold(int gapCleaningThreshold)` Sets the threshold of number of gaps in a token before an attempt to clean gaps up is taken.
`JpaEventStorageEngine.Builder`	`gapTimeout(int gapTimeout)` Sets the amount of time until a 'gap' in a TrackingToken may be considered timed out.
`JpaEventStorageEngine.Builder`	`lowestGlobalSequence(long lowestGlobalSequence)` Sets the `lowestGlobalSequence` specifying the first expected auto generated sequence number.
`JpaEventStorageEngine.Builder`	`maxGapOffset(int maxGapOffset)` Sets the `maxGapOffset` specifying the maximum distance in sequence numbers between a missing event and the event with the highest known index.
`JpaEventStorageEngine.Builder`	`persistenceExceptionResolver(PersistenceExceptionResolver persistenceExceptionResolver)` Sets the `PersistenceExceptionResolver` used to detect concurrency exceptions from the backing database.
`JpaEventStorageEngine.Builder`	`snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)` Deprecated. in favor of `snapshotFilter(SnapshotFilter)`
`JpaEventStorageEngine.Builder`	`snapshotFilter(SnapshotFilter snapshotFilter)` Sets the `snapshotFilter` deciding whether to take a snapshot into account.
`JpaEventStorageEngine.Builder`	`snapshotSerializer(Serializer snapshotSerializer)` Sets the `Serializer` used to serialize and deserialize snapshots.
`JpaEventStorageEngine.Builder`	`transactionManager(TransactionManager transactionManager)` Sets the `TransactionManager` used to manage transaction around fetching event data.
`JpaEventStorageEngine.Builder`	`upcasterChain(EventUpcaster upcasterChain)` Sets the `EventUpcaster` used to deserialize events of older revisions.
`protected void`	`validate()` Validates whether the fields contained in this Builder are set accordingly.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - Builder
```
public Builder()
```
- Method Detail
  - snapshotSerializer
```
public JpaEventStorageEngine.Builder snapshotSerializer(Serializer snapshotSerializer)
```
    Description copied from class: AbstractEventStorageEngine.Builder
    
    Sets the Serializer used to serialize and deserialize snapshots.
    
    Overrides:
    
    snapshotSerializer in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    snapshotSerializer - a Serializer used to serialize and deserialize snapshots
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - upcasterChain
```
public JpaEventStorageEngine.Builder upcasterChain(EventUpcaster upcasterChain)
```
    Description copied from class: AbstractEventStorageEngine.Builder
    
    Sets the EventUpcaster used to deserialize events of older revisions. Defaults to a NoOpEventUpcaster.
    
    Overrides:
    
    upcasterChain in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    upcasterChain - an EventUpcaster used to deserialize events of older revisions
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - persistenceExceptionResolver
```
public JpaEventStorageEngine.Builder persistenceExceptionResolver(PersistenceExceptionResolver persistenceExceptionResolver)
```
    Description copied from class: AbstractEventStorageEngine.Builder
    
    Sets the PersistenceExceptionResolver used to detect concurrency exceptions from the backing database. If the persistenceExceptionResolver is not specified, persistence exceptions are not explicitly resolved.
    
    Overrides:
    
    persistenceExceptionResolver in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    persistenceExceptionResolver - the PersistenceExceptionResolver used to detect concurrency exceptions from the backing database
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - eventSerializer
```
public JpaEventStorageEngine.Builder eventSerializer(Serializer eventSerializer)
```
    Description copied from class: AbstractEventStorageEngine.Builder
    
    Sets the Serializer used to serialize and deserialize the Event Message's payload and MetaData with.
    
    Overrides:
    
    eventSerializer in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    eventSerializer - The serializer to serialize the Event Message's payload and MetaData with
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - finalAggregateBatchPredicate
```
public JpaEventStorageEngine.Builder finalAggregateBatchPredicate(Predicate<List<? extends DomainEventData<?>>> finalAggregateBatchPredicate)
```
    Defines the predicate to use to recognize the terminal batch when reading an event stream for an aggregate. The default behavior is implementation-specific.
    The JpaEventStorageEngine defaults to using any batch smaller than the batch size as the final batch.
    
    Overrides:
    
    finalAggregateBatchPredicate in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    finalAggregateBatchPredicate - The predicate that indicates whether a given batch is to be considered the final batch of an event stream.
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - snapshotFilter
```
@Deprecated
public JpaEventStorageEngine.Builder snapshotFilter(Predicate<? super DomainEventData<?>> snapshotFilter)
```
    Deprecated. in favor of snapshotFilter(SnapshotFilter)
    
    Sets the snapshotFilter deciding whether to take a snapshot into account. Can be set to filter out specific snapshot revisions which should not be applied. Defaults to a Predicate which returns true regardless.
    
    Overrides:
    
    snapshotFilter in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    snapshotFilter - a Predicate which decides whether to take a snapshot into account
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - snapshotFilter
```
public JpaEventStorageEngine.Builder snapshotFilter(SnapshotFilter snapshotFilter)
```
    Description copied from class: AbstractEventStorageEngine.Builder
    
    Sets the snapshotFilter deciding whether to take a snapshot into account. Can be set to filter out specific snapshot revisions which should not be applied. Defaults to SnapshotFilter.allowAll().
    Note that SnapshotFilter instances can be combined and should return true if they handle a snapshot they wish to ignore.
    
    Overrides:
    
    snapshotFilter in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    snapshotFilter - a SnapshotFilter which decides whether to take a snapshot into account
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - batchSize
```
public JpaEventStorageEngine.Builder batchSize(int batchSize)
```
    Description copied from class: BatchingEventStorageEngine.Builder
    
    Sets the batchSize specifying the number of events that should be read at each database access. When more than this number of events must be read to rebuild an aggregate's state, the events are read in batches of this size. Defaults to an integer of 100.
    Tip: if you use a snapshotter, make sure to choose snapshot trigger and batch size such that a single batch will generally retrieve all events required to rebuild an aggregate's state.
    
    Overrides:
    
    batchSize in class BatchingEventStorageEngine.Builder
    
    Parameters:
    
    batchSize - an int specifying the number of events that should be read at each database access
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - dataSource
```
public JpaEventStorageEngine.Builder dataSource(DataSource dataSource)
                                         throws SQLException
```
    Sets the PersistenceExceptionResolver as a SQLErrorCodesResolver, using the provided DataSource to resolve the error codes. Note that the provided DataSource sole purpose in this EventStorageEngine implementation is to be used for instantiating the PersistenceExceptionResolver.
    
    Parameters:
    
    dataSource - the DataSource used to instantiate a SQLErrorCodesResolver(DataSource) as the PersistenceExceptionResolver
    
    Returns:
    
    the current Builder instance, for fluent interfacing
    
    Throws:
    
    SQLException - if creation of the SQLErrorCodesResolver fails
  - entityManagerProvider
```
public JpaEventStorageEngine.Builder entityManagerProvider(EntityManagerProvider entityManagerProvider)
```
    Sets the EntityManagerProvider which provides the EntityManager used to access the underlying database for this EventStorageEngine implementation.
    
    Parameters:
    
    entityManagerProvider - a EntityManagerProvider which provides the EntityManager used to access the underlying database
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - transactionManager
```
public JpaEventStorageEngine.Builder transactionManager(TransactionManager transactionManager)
```
    Sets the TransactionManager used to manage transaction around fetching event data. Required by certain databases for reading blob data.
    
    Parameters:
    
    transactionManager - a TransactionManager used to manage transaction around fetching event data
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - explicitFlush
```
public JpaEventStorageEngine.Builder explicitFlush(boolean explicitFlush)
```
    Sets the explicitFlush field specifying whether to explicitly call EntityManager.flush() after inserting the Events published in this Unit of Work. If false, this instance relies on the TransactionManager to flush data. Note that the persistenceExceptionResolver may not be able to translate exceptions anymore. false should only be used to optimize performance for batch operations. In other cases, true is recommended, which is also the default.
    
    Parameters:
    
    explicitFlush - a boolean specifying whether to explicitly call EntityManager.flush() after inserting the Events published in this Unit of Work
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - maxGapOffset
```
public JpaEventStorageEngine.Builder maxGapOffset(int maxGapOffset)
```
    Sets the maxGapOffset specifying the maximum distance in sequence numbers between a missing event and the event with the highest known index. If the gap is bigger it is assumed that the missing event will not be committed to the store anymore. This event storage engine will no longer look for those events the next time a batch is fetched. Defaults to an integer of 10000 (JpaEventStorageEngine.DEFAULT_MAX_GAP_OFFSET.
    
    Parameters:
    
    maxGapOffset - an int specifying the maximum distance in sequence numbers between a missing event and the event with the highest known index
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - lowestGlobalSequence
```
public JpaEventStorageEngine.Builder lowestGlobalSequence(long lowestGlobalSequence)
```
    Sets the lowestGlobalSequence specifying the first expected auto generated sequence number. For most data stores this is 1 unless the table has contained entries before. Defaults to a long of 1 (JpaEventStorageEngine.DEFAULT_LOWEST_GLOBAL_SEQUENCE).
    
    Parameters:
    
    lowestGlobalSequence - a long specifying the first expected auto generated sequence number
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - gapTimeout
```
public JpaEventStorageEngine.Builder gapTimeout(int gapTimeout)
```
    Sets the amount of time until a 'gap' in a TrackingToken may be considered timed out. This setting will affect the cleaning process of gaps. Gaps that have timed out will be removed from Tracking Tokens to improve performance of reading events. Defaults to an integer of 60000 (JpaEventStorageEngine.DEFAULT_GAP_TIMEOUT), thus 1 minute.
    
    Parameters:
    
    gapTimeout - an int specifying the amount of time in milliseconds until a 'gap' in a TrackingToken may be considered timed out
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - gapCleaningThreshold
```
public JpaEventStorageEngine.Builder gapCleaningThreshold(int gapCleaningThreshold)
```
    Sets the threshold of number of gaps in a token before an attempt to clean gaps up is taken. Defaults to an integer of 250 (JpaEventStorageEngine.DEFAULT_GAP_CLEANING_THRESHOLD).
    
    Parameters:
    
    gapCleaningThreshold - an int specifying the threshold of number of gaps in a token before an attempt to clean gaps up is taken
    
    Returns:
    
    the current Builder instance, for fluent interfacing
  - build
```
public JpaEventStorageEngine build()
```
    Initializes a JpaEventStorageEngine as specified through this Builder.
    
    Returns:
    
    a JpaEventStorageEngine as specified through this Builder
  - validate
```
protected void validate()
                 throws AxonConfigurationException
```
    Validates whether the fields contained in this Builder are set accordingly.
    
    Overrides:
    
    validate in class BatchingEventStorageEngine.Builder
    
    Throws:
    
    AxonConfigurationException - if one field is asserted to be incorrect according to the Builder's specifications

Class JpaEventStorageEngine.Builder

Field Summary

Fields inherited from class org.axonframework.eventsourcing.eventstore.AbstractEventStorageEngine.Builder

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Builder

Method Detail

snapshotSerializer

upcasterChain

persistenceExceptionResolver

eventSerializer

finalAggregateBatchPredicate

snapshotFilter

snapshotFilter

batchSize

dataSource

entityManagerProvider

transactionManager

explicitFlush

maxGapOffset

lowestGlobalSequence

gapTimeout

gapCleaningThreshold

build

validate