public class AcknowledgeService extends AbstractService implements IAcknowledgeService
IAcknowledgeServicelog, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
AcknowledgeService(ISymmetricEngine engine) |
| Modifier and Type | Method and Description |
|---|---|
BatchAckResult |
ack(BatchAck batch) |
java.util.List<BatchAckResult> |
ack(java.util.List<BatchAck> batches) |
protected void |
purgeLoadBatchesFromStaging(OutgoingBatch outgoingBatch) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic AcknowledgeService(ISymmetricEngine engine)
public BatchAckResult ack(BatchAck batch)
ack in interface IAcknowledgeServiceprotected void purgeLoadBatchesFromStaging(OutgoingBatch outgoingBatch)
public java.util.List<BatchAckResult> ack(java.util.List<BatchAck> batches)
ack in interface IAcknowledgeService