org.jumpmind.symmetric.service.impl

Class PurgeService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.PurgeService

All Implemented Interfaces:

IPurgeService, IService

public class PurgeService
extends AbstractService
implements IPurgeService

See Also:

IPurgeService

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
PurgeService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IClusterService clusterService, IStatisticManager statisticManager, IExtensionService extensionService, IContextService contextService)

Method Summary

Modifier and Type	Method and Description
protected int	executePurgeDelete(java.lang.String deleteSql, java.lang.Object argument)
void	purgeAllIncomingEventsForNode(java.lang.String nodeId)
long	purgeIncoming(boolean force)
long	purgeIncoming(java.util.Calendar retentionCutoff, boolean force)
long	purgeOutgoing(boolean force)
long	purgeOutgoing(java.util.Calendar retentionCutoff, boolean force)
protected long	purgeOutgoingByRetentionCutoff(java.util.Calendar retentionCutoff)
void	purgeStats(boolean force)
protected void	saveContextLastId(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier, long lastId)
protected int	selectIdsAndDelete(java.lang.String selectSql, java.lang.String fieldName, java.lang.String deleteSql)

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

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, 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 Detail

PurgeService

public PurgeService(IParameterService parameterService,
                    ISymmetricDialect symmetricDialect,
                    IClusterService clusterService,
                    IStatisticManager statisticManager,
                    IExtensionService extensionService,
                    IContextService contextService)

Method Detail

purgeOutgoing

public long purgeOutgoing(boolean force)

Specified by:

purgeOutgoing in interface IPurgeService

purgeIncoming

public long purgeIncoming(boolean force)

Specified by:

purgeIncoming in interface IPurgeService

purgeOutgoing

public long purgeOutgoing(java.util.Calendar retentionCutoff,
                          boolean force)

Specified by:

purgeOutgoing in interface IPurgeService

purgeOutgoingByRetentionCutoff

protected long purgeOutgoingByRetentionCutoff(java.util.Calendar retentionCutoff)

executePurgeDelete

protected int executePurgeDelete(java.lang.String deleteSql,
                                 java.lang.Object argument)

saveContextLastId

protected void saveContextLastId(org.jumpmind.symmetric.service.impl.PurgeService.MinMaxDeleteSql identifier,
                                 long lastId)

purgeIncoming

public long purgeIncoming(java.util.Calendar retentionCutoff,
                          boolean force)

Specified by:

purgeIncoming in interface IPurgeService

purgeStats

public void purgeStats(boolean force)

Specified by:

purgeStats in interface IPurgeService

purgeAllIncomingEventsForNode

public void purgeAllIncomingEventsForNode(java.lang.String nodeId)

Specified by:

purgeAllIncomingEventsForNode in interface IPurgeService

selectIdsAndDelete

protected int selectIdsAndDelete(java.lang.String selectSql,
                                 java.lang.String fieldName,
                                 java.lang.String deleteSql)