org.jumpmind.symmetric.service.impl
Class PurgeService

java.lang.Object
  org.jumpmind.symmetric.service.impl.PurgeService

All Implemented Interfaces:

IPurgeService

public class PurgeService
extends java.lang.Object
implements IPurgeService

Field Summary

protected org.springframework.jdbc.core.JdbcTemplate	jdbcTemplate
protected IParameterService	parameterService

Constructor Summary

PurgeService()

Method Summary

protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate	getSimpleTemplate()
java.lang.String	getSql(java.lang.String key)
void	purge()
void	purgeAllIncomingEventsForNode(java.lang.String nodeId)
void	purgeAllOutgoingEventsForNode(java.lang.String nodeId)
void	setClusterService(IClusterService clusterService)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbc)
void	setParameterService(IParameterService parameterService)
void	setSql(java.util.Map<java.lang.String,java.lang.String> sql)
protected java.sql.SQLException	unwrapSqlException(java.lang.Throwable e)

Methods inherited from class java.lang.Object

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

Field Detail

parameterService

protected IParameterService parameterService

jdbcTemplate

protected org.springframework.jdbc.core.JdbcTemplate jdbcTemplate

Constructor Detail

PurgeService

public PurgeService()

Method Detail

purge

public void purge()

Specified by:

purge in interface IPurgeService

purgeAllIncomingEventsForNode

public void purgeAllIncomingEventsForNode(java.lang.String nodeId)

Specified by:

purgeAllIncomingEventsForNode in interface IPurgeService

purgeAllOutgoingEventsForNode

public void purgeAllOutgoingEventsForNode(java.lang.String nodeId)

Specified by:

purgeAllOutgoingEventsForNode in interface IPurgeService

setClusterService

public void setClusterService(IClusterService clusterService)

setJdbcTemplate

public void setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbc)

getSimpleTemplate

protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate getSimpleTemplate()

unwrapSqlException

protected java.sql.SQLException unwrapSqlException(java.lang.Throwable e)

setSql

public void setSql(java.util.Map<java.lang.String,java.lang.String> sql)

getSql

public java.lang.String getSql(java.lang.String key)

setParameterService

public void setParameterService(IParameterService parameterService)