public class DeadLetterSchema extends Object
EventMessage holding
DeadLetter entry table in JDBC.| Modifier and Type | Class and Description |
|---|---|
static class |
DeadLetterSchema.Builder
Instantiate a builder to construct a
DeadLetterSchema. |
| Modifier | Constructor and Description |
|---|---|
protected |
DeadLetterSchema(DeadLetterSchema.Builder builder)
Instantiate a
DeadLetterSchema based on the given builder. |
| Modifier and Type | Method and Description |
|---|---|
String |
aggregateIdentifierColumn()
Returns the configured
aggregateIdentifier column name. |
String |
aggregateTypeColumn()
Returns the configured
aggregateType column name. |
static DeadLetterSchema.Builder |
builder()
Instantiate a builder to construct a
DeadLetterSchema. |
String |
causeMessageColumn()
Returns the configured
causeMessage column name. |
String |
causeTypeColumn()
Returns the configured
causeType column name. |
String |
deadLetterFields()
Return a comma separated list of dead letter column names to insert a dead letter into the
dead letter table. |
String |
deadLetterIdentifierColumn()
Returns the configured
deadLetterIdentifier column name. |
String |
deadLetterTable()
Returns the configured
deadLetter table name. |
static DeadLetterSchema |
defaultSchema()
Instantiate a default
DeadLetterSchema using the pre-configured column names. |
String |
diagnosticsColumn()
Returns the configured
diagnostics column name. |
String |
enqueuedAtColumn()
Returns the configured
enqueuedAt column name. |
String |
eventIdentifierColumn()
Returns the configured
eventIdentifier column name. |
String |
lastTouchedColumn()
Returns the configured
lastTouched column name. |
String |
messageTypeColumn()
Returns the configured
messageType column name. |
String |
metaDataColumn()
Returns the configured
metaData column name. |
String |
payloadColumn()
Returns the configured
payload column name. |
String |
payloadRevisionColumn()
Returns the configured
payloadRevision column name. |
String |
payloadTypeColumn()
Returns the configured
payloadType column name. |
String |
processingGroupColumn()
Returns the configured
processingGroup column name. |
String |
processingStartedColumn()
Returns the configured
processingStarted column name. |
String |
sequenceIdentifierColumn()
Returns the configured
sequenceIdentifier column name. |
String |
sequenceIndexColumn()
Returns the configured
sequenceIndex column name. |
String |
sequenceNumberColumn()
Returns the configured
sequenceNumber column name. |
String |
timestampColumn()
Returns the configured
timestamp column name. |
String |
tokenColumn()
Returns the configured
token column name. |
String |
tokenTypeColumn()
Returns the configured
tokenType column name. |
protected DeadLetterSchema(DeadLetterSchema.Builder builder)
DeadLetterSchema based on the given builder.builder - The DeadLetterSchema.Builder used to instantiate a DeadLetterSchema instance.public static DeadLetterSchema.Builder builder()
DeadLetterSchema.
All configurable columns default to their respective field name. Thus, the result of the
diagnosticsColumn() defaults to diagnosticsColumn, etc.
DeadLetterSchema.public static DeadLetterSchema defaultSchema()
DeadLetterSchema using the pre-configured column names.DeadLetterSchema using the pre-configured column namespublic String deadLetterTable()
deadLetter table name.deadLetter table name.public String deadLetterIdentifierColumn()
deadLetterIdentifier column name.deadLetterIdentifier column name.public String processingGroupColumn()
processingGroup column name.processingGroup column name.public String sequenceIdentifierColumn()
sequenceIdentifier column name.sequenceIdentifier column name.public String sequenceIndexColumn()
sequenceIndex column name.sequenceIndex column name.public String messageTypeColumn()
messageType column name.messageType column name.public String eventIdentifierColumn()
eventIdentifier column name.eventIdentifier column name.public String timestampColumn()
timestamp column name.timestamp column name.public String payloadTypeColumn()
payloadType column name.payloadType column name.public String payloadRevisionColumn()
payloadRevision column name.payloadRevision column name.public String payloadColumn()
payload column name.payload column name.public String metaDataColumn()
metaData column name.metaData column name.public String aggregateTypeColumn()
aggregateType column name.aggregateType column name.public String aggregateIdentifierColumn()
aggregateIdentifier column name.aggregateIdentifier column name.public String sequenceNumberColumn()
sequenceNumber column name.sequenceNumber column name.public String tokenTypeColumn()
tokenType column name.tokenType column name.public String tokenColumn()
token column name.token column name.public String enqueuedAtColumn()
enqueuedAt column name.enqueuedAt column name.public String lastTouchedColumn()
lastTouched column name.lastTouched column name.public String processingStartedColumn()
processingStarted column name.processingStarted column name.public String causeTypeColumn()
causeType column name.causeType column name.public String causeMessageColumn()
causeMessage column name.causeMessage column name.public String diagnosticsColumn()
diagnostics column name.diagnostics column name.public String deadLetterFields()
dead letter table.Copyright © 2010–2025. All rights reserved.