Package org.axonframework.messaging.eventhandling.deadletter.jdbc

Class GenericDeadLetterTableFactory

java.lang.Object

org.axonframework.messaging.eventhandling.deadletter.jdbc.GenericDeadLetterTableFactory

All Implemented Interfaces:

DeadLetterTableFactory

public class GenericDeadLetterTableFactory
extends Object
implements DeadLetterTableFactory

A DeadLetterTableFactory implementation compatible with most databases.

Since:

4.8.0

Author:

Steven van Beelen

Constructor Summary

Constructors

Constructor	Description
GenericDeadLetterTableFactory()

Method Summary

Modifier and Type	Method	Description
protected String	createTableSql(DeadLetterSchema schema)	Constructs the SQL to create a dead-letter table, using the given schema to deduce the table and column names.
Statement	createTableStatement(Connection connection, DeadLetterSchema schema)	Creates a Statement to use for construction of a DeadLetter entry table and its indices.
protected String	processingGroupIndexSql(DeadLetterSchema schema)	Constructs the SQL to create an index of the processing group , using the given schema to deduce the table and column names.
protected String	sequenceIdentifierIndexSql(DeadLetterSchema schema)	Constructs the SQL to create an index for the processing group and sequence indentifier combination, using the given schema to deduce the table and column names.
protected String	serializedDataType()	Returns the SQL to describe the type for serialized data columns.
protected String	timestampType()	Returns the SQL to describe the type for timestamp columns.

Methods inherited from class java.lang.Object

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

Constructor Details

GenericDeadLetterTableFactory

public GenericDeadLetterTableFactory()

Method Details

createTableStatement

public Statement createTableStatement(Connection connection,
 DeadLetterSchema schema)
                               throws SQLException

Description copied from interface: DeadLetterTableFactory

Creates a Statement to use for construction of a DeadLetter entry table and its indices.

The returned Statement typically contains several SQL statements and hence the invoker is inclined to execute the Statement as a batch by invoking Statement.executeBatch(). Furthermore, it is expected that this statement at least constructs the required uniqueness constraints.

Specified by:

createTableStatement in interface DeadLetterTableFactory

Parameters:

connection - The connection to create the Statement with.

schema - The schema defining the table and column names.

Returns:

A statement to create the table and its indices with, ready to be executed.

Throws:

SQLException - when an exception occurs while creating the Statement.

createTableSql

protected String createTableSql(DeadLetterSchema schema)

Constructs the SQL to create a dead-letter table, using the given schema to deduce the table and column names.

Parameters:

schema - The schema defining the table and column names.

Returns:

The SQL to construct the dead-letter table.

processingGroupIndexSql

protected String processingGroupIndexSql(DeadLetterSchema schema)

Constructs the SQL to create an index of the processing group , using the given schema to deduce the table and column names.

Parameters:

schema - The schema defining the table and column names.

Returns:

The SQL to construct the index for the processing group for the dead-letter table.

sequenceIdentifierIndexSql

protected String sequenceIdentifierIndexSql(DeadLetterSchema schema)

Constructs the SQL to create an index for the processing group and sequence indentifier combination, using the given schema to deduce the table and column names.

Parameters:

schema - The schema defining the table and column names.

Returns:

The SQL to construct the index for processing group and invalid input: 'combination for the dead-letter table.'

serializedDataType

protected String serializedDataType()

Returns the SQL to describe the type for serialized data columns.

Used for the DeadLetterSchema.payloadColumn(), DeadLetterSchema.metadataColumn(), DeadLetterSchema.tokenColumn(), and the DeadLetterSchema.diagnosticsColumn(). Defaults to BLOB.

Returns:

The SQL to describe the type for serialized data columns.

timestampType

protected String timestampType()

Returns the SQL to describe the type for timestamp columns.

Used for the DeadLetterSchema.enqueuedAtColumn(), DeadLetterSchema.lastTouchedColumn(), DeadLetterSchema.processingGroupColumn(), and the DeadLetterSchema.timestampColumn(). Defaults to VARCHAR(255).

Returns:

The SQL to describe the type for timestamp columns.