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–2024. All rights reserved.