Package | Description |
---|---|
org.axonframework.eventhandling.deadletter.jdbc |
Modifier and Type | Method and Description |
---|---|
static <E extends EventMessage<?>> |
JdbcSequencedDeadLetterQueue.builder()
Instantiate a builder to construct a
JdbcSequencedDeadLetterQueue . |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.claimDuration(Duration claimDuration)
Sets the claim duration, which is the time a dead-letter gets locked when processing and waiting for it to
complete.
|
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.connectionProvider(ConnectionProvider connectionProvider)
Sets the
ConnectionProvider which provides access to a JDBC connection. |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.converter(DeadLetterJdbcConverter<E,? extends JdbcDeadLetter<E>> converter)
|
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.eventSerializer(Serializer eventSerializer)
Sets the
Serializer to (de)serialize the events, metadata and diagnostics of the DeadLetter
when storing it to a database. |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.genericSerializer(Serializer genericSerializer)
Sets the
Serializer to (de)serialize the TrackingToken (if
present) of the event in the DeadLetter when storing it to the database. |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.maxSequences(int maxSequences)
Sets the maximum number of unique sequences this
SequencedDeadLetterQueue may contain. |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.maxSequenceSize(int maxSequenceSize)
Sets the maximum amount of
letters per unique sequences this
SequencedDeadLetterQueue can store. |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.pageSize(int pageSize)
Modifies the page size used when retrieving a sequence of dead letters.
|
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.processingGroup(String processingGroup)
Sets the processing group, which is used for storing and querying which processing group a dead-lettered
EventMessage belonged to. |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.schema(DeadLetterSchema schema)
Sets the
DeadLetterSchema used to constructs the table and indices required by this
SequencedDeadLetterQueue . |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.statementFactory(DeadLetterStatementFactory<E> statementFactory)
Sets the
DeadLetterStatementFactory used to construct all
PreparedStatements executed by this SequencedDeadLetterQueue . |
JdbcSequencedDeadLetterQueue.Builder<E> |
JdbcSequencedDeadLetterQueue.Builder.transactionManager(TransactionManager transactionManager)
Sets the
TransactionManager used to manage transaction around fetching dead-letter data. |
Constructor and Description |
---|
JdbcSequencedDeadLetterQueue(JdbcSequencedDeadLetterQueue.Builder<E> builder)
Instantiate a JDBC-based
SequencedDeadLetterQueue through the given builder . |
Copyright © 2010–2024. All rights reserved.