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

Class DeadLetterSchema

java.lang.Object
org.axonframework.messaging.eventhandling.deadletter.jdbc.DeadLetterSchema
public class DeadLetterSchema extends Object
Schema description for an EventMessage holding DeadLetter entry table in JDBC.
Since:
4.8.0
Author:
Steven van Beelen

  • Constructor Details

  • Method Details

    • builder

      public static DeadLetterSchema.Builder builder()
      Instantiate a builder to construct a DeadLetterSchema.

      All configurable columns default to their respective field name. Thus, the result of the diagnosticsColumn() defaults to diagnosticsColumn, etc.

      Returns:
      A Builder that can construct a DeadLetterSchema.

    • defaultSchema

      public static DeadLetterSchema defaultSchema()
      Instantiate a default DeadLetterSchema using the pre-configured column names.
      Returns:
      A default DeadLetterSchema using the pre-configured column names

    • deadLetterTable

      public String deadLetterTable()
      Returns the configured deadLetter table name.
      Returns:
      The configured deadLetter table name.

    • deadLetterIdentifierColumn

      public String deadLetterIdentifierColumn()
      Returns the configured deadLetterIdentifier column name.
      Returns:
      The configured deadLetterIdentifier column name.

    • processingGroupColumn

      public String processingGroupColumn()
      Returns the configured processingGroup column name.
      Returns:
      The configured processingGroup column name.

    • sequenceIdentifierColumn

      public String sequenceIdentifierColumn()
      Returns the configured sequenceIdentifier column name.
      Returns:
      The configured sequenceIdentifier column name.

    • sequenceIndexColumn

      public String sequenceIndexColumn()
      Returns the configured sequenceIndex column name.
      Returns:
      The configured sequenceIndex column name.

    • eventTypeColumn

      public String eventTypeColumn()
      Returns the configured eventType column name.
      Returns:
      The configured eventType column name.

    • eventIdentifierColumn

      public String eventIdentifierColumn()
      Returns the configured eventIdentifier column name.
      Returns:
      The configured eventIdentifier column name.

    • typeColumn

      public String typeColumn()
      Returns the configured typeColumn column name.

      Represents the Message.type() field, based on the MessageType.toString() output.

      Returns:
      The configured typeColumn column qualifiedName.

    • timestampColumn

      public String timestampColumn()
      Returns the configured timestamp column name.
      Returns:
      The configured timestamp column name.

    • payloadColumn

      public String payloadColumn()
      Returns the configured payload column name.
      Returns:
      The configured payload column name.

    • metadataColumn

      public String metadataColumn()
      Returns the configured metadata column name.
      Returns:
      The configured metadata column name.

    • aggregateTypeColumn

      public String aggregateTypeColumn()
      Returns the configured aggregateType column name.
      Returns:
      The configured aggregateType column name.

    • aggregateIdentifierColumn

      public String aggregateIdentifierColumn()
      Returns the configured aggregateIdentifier column name.
      Returns:
      The configured aggregateIdentifier column name.

    • sequenceNumberColumn

      public String sequenceNumberColumn()
      Returns the configured sequenceNumber column name.
      Returns:
      The configured sequenceNumber column name.

    • tokenTypeColumn

      public String tokenTypeColumn()
      Returns the configured tokenType column name.
      Returns:
      The configured tokenType column name.

    • tokenColumn

      public String tokenColumn()
      Returns the configured token column name.
      Returns:
      The configured token column name.

    • enqueuedAtColumn

      public String enqueuedAtColumn()
      Returns the configured enqueuedAt column name.
      Returns:
      The configured enqueuedAt column name.

    • lastTouchedColumn

      public String lastTouchedColumn()
      Returns the configured lastTouched column name.
      Returns:
      The configured lastTouched column name.

    • processingStartedColumn

      public String processingStartedColumn()
      Returns the configured processingStarted column name.
      Returns:
      The configured processingStarted column name.

    • causeTypeColumn

      public String causeTypeColumn()
      Returns the configured causeType column name.
      Returns:
      The configured causeType column name.

    • causeMessageColumn

      public String causeMessageColumn()
      Returns the configured causeMessage column name.
      Returns:
      The configured causeMessage column name.

    • diagnosticsColumn

      public String diagnosticsColumn()
      Returns the configured diagnostics column name.
      Returns:
      The configured diagnostics column name.

    • deadLetterFields

      public String deadLetterFields()
      Return a comma separated list of dead letter column names to insert a dead letter into the dead letter table.
      Returns:
      A comma separated list of dead letter column names.