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

Class DeadLetterSchema.Builder

java.lang.Object
org.axonframework.messaging.eventhandling.deadletter.jdbc.DeadLetterSchema.Builder
Enclosing class:
DeadLetterSchema
public static class DeadLetterSchema.Builder extends Object
Instantiate a builder to construct a DeadLetterSchema.

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

  • Constructor Details

    • Builder

      public Builder()

  • Method Details

    • deadLetterTable

      public DeadLetterSchema.Builder deadLetterTable(String deadLetterTable)
      Sets the name of the dead-letter table. Defaults to DeadLetterEntry.
      Parameters:
      deadLetterTable - The name for the dead-letter table.
      Returns:
      The current Builder instance, for fluent interfacing.

    • deadLetterIdentifierColumn

      public DeadLetterSchema.Builder deadLetterIdentifierColumn(String deadLetterIdentifierColumn)
      Sets the name of the deadLetterIdentifier column. Defaults to deadLetterIdentifier.
      Parameters:
      deadLetterIdentifierColumn - The name for the deadLetterIdentifier column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • processingGroupColumn

      public DeadLetterSchema.Builder processingGroupColumn(String processingGroupColumn)
      Sets the name of the processingGroup column. Defaults to processingGroup.
      Parameters:
      processingGroupColumn - The name for the processingGroup column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • sequenceIdentifierColumn

      public DeadLetterSchema.Builder sequenceIdentifierColumn(String sequenceIdentifierColumn)
      Sets the name of the sequenceIdentifier column. Defaults to sequenceIdentifier.
      Parameters:
      sequenceIdentifierColumn - The name for the sequenceIdentifier column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • sequenceIndexColumn

      public DeadLetterSchema.Builder sequenceIndexColumn(String sequenceIndexColumn)
      Sets the name of the sequenceIndex column. Defaults to sequenceIndex.
      Parameters:
      sequenceIndexColumn - The name for the sequenceIndex column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • eventTypeColumn

      public DeadLetterSchema.Builder eventTypeColumn(String eventTypeColumn)
      Sets the name of the eventType column. Defaults to eventType.
      Parameters:
      eventTypeColumn - The name for the eventType column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • eventIdentifierColumn

      public DeadLetterSchema.Builder eventIdentifierColumn(String eventIdentifierColumn)
      Sets the name of the eventIdentifier column. Defaults to eventIdentifier.
      Parameters:
      eventIdentifierColumn - The name for the eventIdentifier column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • typeColumn

      public DeadLetterSchema.Builder typeColumn(String typeColumn)
      Sets the name of the type column. Defaults to type.
      Parameters:
      typeColumn - The qualifiedName for the type column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • timestampColumn

      public DeadLetterSchema.Builder timestampColumn(String timestampColumn)
      Sets the name of the timestamp column. Defaults to timestamp.
      Parameters:
      timestampColumn - The name for the timeStamp column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • payloadColumn

      public DeadLetterSchema.Builder payloadColumn(String payloadColumn)
      Sets the name of the payload column. Defaults to payload.
      Parameters:
      payloadColumn - The name for the payload column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • metadataColumn

      public DeadLetterSchema.Builder metadataColumn(String metadataColumn)
      Sets the name of the metadata column. Defaults to metadata.
      Parameters:
      metadataColumn - The name for the metadata column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • aggregateTypeColumn

      public DeadLetterSchema.Builder aggregateTypeColumn(String aggregateTypeColumn)
      Sets the name of the aggregateType column. Defaults to type.
      Parameters:
      aggregateTypeColumn - The name for the aggregateType column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • aggregateIdentifierColumn

      public DeadLetterSchema.Builder aggregateIdentifierColumn(String aggregateIdentifierColumn)
      Sets the name of the aggregateIdentifier column. Defaults to aggregateIdentifier.
      Parameters:
      aggregateIdentifierColumn - The name for the aggregateIdentifier column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • sequenceNumberColumn

      public DeadLetterSchema.Builder sequenceNumberColumn(String sequenceNumberColumn)
      Sets the name of the sequenceNumber column. Defaults to sequenceNumber.
      Parameters:
      sequenceNumberColumn - The name for the sequenceNumber column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • tokenTypeColumn

      public DeadLetterSchema.Builder tokenTypeColumn(String tokenTypeColumn)
      Sets the name of the tokenType column. Defaults to tokenType.
      Parameters:
      tokenTypeColumn - The name for the tokenType column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • tokenColumn

      public DeadLetterSchema.Builder tokenColumn(String tokenColumn)
      Sets the name of the token column. Defaults to token.
      Parameters:
      tokenColumn - The name for the token column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • enqueuedAtColumn

      public DeadLetterSchema.Builder enqueuedAtColumn(String enqueuedAtColumn)
      Sets the name of the enqueuedAt column. Defaults to enqueuedAt.
      Parameters:
      enqueuedAtColumn - The name for the enqueuedAt column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • lastTouchedColumn

      public DeadLetterSchema.Builder lastTouchedColumn(String lastTouchedColumn)
      Sets the name of the lastTouched column. Defaults to lastTouched.
      Parameters:
      lastTouchedColumn - The name for the lastTouched column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • processingStartedColumn

      public DeadLetterSchema.Builder processingStartedColumn(String processingStartedColumn)
      Sets the name of the processingStarted column. Defaults to processingStarted.
      Parameters:
      processingStartedColumn - The name for the processingStarted column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • causeTypeColumn

      public DeadLetterSchema.Builder causeTypeColumn(String causeTypeColumn)
      Sets the name of the causeType column. Defaults to causeType.
      Parameters:
      causeTypeColumn - The name for the causeType column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • causeMessageColumn

      public DeadLetterSchema.Builder causeMessageColumn(String causeMessageColumn)
      Sets the name of the causeMessage column. Defaults to causeMessage.
      Parameters:
      causeMessageColumn - The name for the causeMessage column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • diagnosticsColumn

      public DeadLetterSchema.Builder diagnosticsColumn(String diagnosticsColumn)
      Sets the name of the diagnostics column. Defaults to diagnostics.
      Parameters:
      diagnosticsColumn - The name for the diagnostics column.
      Returns:
      The current Builder instance, for fluent interfacing.

    • build

      public DeadLetterSchema build()
      Initializes a DeadLetterSchema as specified through this Builder.
      Returns:
      A DeadLetterSchema as specified through this Builder.