Package org.jumpmind.symmetric.service.impl

Class AcknowledgeService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.AcknowledgeService

All Implemented Interfaces:

IAcknowledgeService, IService

public class AcknowledgeService
extends AbstractService
implements IAcknowledgeService

See Also:

• IAcknowledgeService

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
AcknowledgeService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
List<BatchAckResult>	ack(List<BatchAck> batches)
BatchAckResult	ack(BatchAck batch)
void	checkMissingAck(List<BatchAck> acks, String queue)
protected void	purgeBatchesFromStaging(OutgoingBatch outgoingBatch)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Details

AcknowledgeService

public AcknowledgeService(ISymmetricEngine engine)

Method Details

ack

public BatchAckResult ack(BatchAck batch)

Specified by:

ack in interface IAcknowledgeService

purgeBatchesFromStaging

protected void purgeBatchesFromStaging(OutgoingBatch outgoingBatch)

ack

public List<BatchAckResult> ack(List<BatchAck> batches)

Specified by:

ack in interface IAcknowledgeService

checkMissingAck

public void checkMissingAck(List<BatchAck> acks,
 String queue)

Specified by:

checkMissingAck in interface IAcknowledgeService