Class EsbProcessedMessageTable

java.lang.Object

com.kingsrook.qqq.esb.outbox.EsbProcessedMessageTable

public final class EsbProcessedMessageTable
extends Object

The processed-message table for idempotent triggers: one row per message a trigger processed, keyed (uniquely, in the database) by trigger name and message id. Rows older than the dedupe retentionDays are purged. Columns are snake_case; there are no foreign keys. The application adds the table to its instance (defineTable) and creates it in its migrations (the PostgreSQL DDL is in docs/esb/index.adoc).

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FIELD_ID
static final String	FIELD_MESSAGE_ID
static final String	FIELD_PROCESSED_AT
static final String	FIELD_TRIGGER_NAME

Method Summary

Modifier and Type	Method	Description
static QTableMetaData	defineTable(String tableName, String backendName)	The processed-message table, on the given backend.

Methods inherited from class java.lang.Object

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

Field Details

FIELD_ID

public static final String FIELD_ID

See Also:

• Constant Field Values

FIELD_TRIGGER_NAME

public static final String FIELD_TRIGGER_NAME

See Also:

• Constant Field Values

FIELD_MESSAGE_ID

public static final String FIELD_MESSAGE_ID

See Also:

• Constant Field Values

FIELD_PROCESSED_AT

public static final String FIELD_PROCESSED_AT

See Also:

• Constant Field Values

Method Details

defineTable

public static QTableMetaData defineTable(String tableName,
 String backendName)

The processed-message table, on the given backend.