Package org.jumpmind.symmetric.service.impl

Class AbstractService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

All Implemented Interfaces:

IService

Direct Known Subclasses:

AbstractOfflineDetectorService, AcknowledgeService, ClusterService, ConfigurationService, ContextService, DataExtractorService, DataLoaderService, DataService, ExtensionService, GroupletService, IncomingBatchService, InitialLoadService, JobManager, LoadFilterService, NodeCommunicationService, NodeService, OfflinePullService, OfflinePushService, OutgoingBatchService, PurgeService, RegistrationService, RouterService, SequenceService, StatisticService, TestTablesService, TransformService, TriggerRouterService, UpdateService

public abstract class AbstractService
extends Object
implements IService

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.slf4j.Logger	log
protected IParameterService	parameterService
protected IDatabasePlatform	platform
protected ISqlTemplate	sqlTemplate
protected ISqlTemplate	sqlTemplateDirty
protected ISymmetricDialect	symmetricDialect
protected String	tablePrefix

Constructor Summary

Constructors

Constructor	Description
AbstractService()
AbstractService(IParameterService parameterService, ISymmetricDialect symmetricDialect)

Method Summary

Modifier and Type	Method	Description
protected void	assertNotNull(Object o, String message)
protected String	buildBatchOrderBy(String orderColumn, String orderDirection)
protected Map<String,Object>	buildBatchParams(List<FilterCriterion> filter)
protected String	buildBatchWhere(List<String> nodeIds, List<String> channels, List<?> statuses, List<Long> loads, Date startAtLastUpdatedTime)
protected String	buildBatchWhereFromFilter(List<FilterCriterion> filter)
protected void	close(ISqlTransaction transaction)
protected Map<String,String>	createSqlReplacementTokens()
ISqlTemplate	getJdbcTemplate()
IParameterService	getParameterService()
String	getSql(String... keys)
ISymmetricDialect	getSymmetricDialect()
String	getTablePrefix()
protected ISymmetricDialect	getTargetDialect()
protected IDatabasePlatform	getTargetPlatform()
protected IDatabasePlatform	getTargetPlatform(String tableName)
protected boolean	isCalledFromSymmetricAdminTool()
protected boolean	isSet(Object value)
protected boolean	isStreamClosedByClient(Exception ex)
protected boolean	isSymmetricTable(String tableName)
protected void	logOnce(String message)
protected Date	maxDate(Date... dates)
protected List<BatchAck>	readAcks(List<OutgoingBatch> batches, IOutgoingWithResponseTransport transport, ITransportManager transportManager, IAcknowledgeService acknowledgeService, IDataExtractorService dataExtratorService)
protected void	sendAck(Node remote, Node local, NodeSecurity localSecurity, List<IncomingBatch> list, ITransportManager transportManager, String queue)	Try a configured number of times to get the ACK through.
protected void	setSqlMap(ISqlMap sqlMap)
void	synchronize(Runnable runnable)	Provide a mechanism where service clients may synchronize custom code with synchronized code in SymmetricDS services.
protected Set<String>	toNodeIds(Set<Node> nodes)
protected Set<String>	toNodeIds(Set<Node> nodes, Set<String> nodeIds)

Methods inherited from class java.lang.Object

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

Field Details

log

protected final org.slf4j.Logger log

parameterService

protected IParameterService parameterService

symmetricDialect

protected ISymmetricDialect symmetricDialect

sqlTemplate

protected ISqlTemplate sqlTemplate

sqlTemplateDirty

protected ISqlTemplate sqlTemplateDirty

platform

protected IDatabasePlatform platform

tablePrefix

protected String tablePrefix

Constructor Details

AbstractService

public AbstractService()

AbstractService

public AbstractService(IParameterService parameterService,
 ISymmetricDialect symmetricDialect)

Method Details

maxDate

protected Date maxDate(Date... dates)

setSqlMap

protected void setSqlMap(ISqlMap sqlMap)

getJdbcTemplate

public ISqlTemplate getJdbcTemplate()

synchronize

public void synchronize(Runnable runnable)

Description copied from interface: IService

Provide a mechanism where service clients may synchronize custom code with synchronized code in SymmetricDS services.

Specified by:

synchronize in interface IService

Parameters:

runnable - The code to run

isSet

protected boolean isSet(Object value)

createSqlReplacementTokens

protected Map<String,String> createSqlReplacementTokens()

getSql

public String getSql(String... keys)

Specified by:

getSql in interface IService

getParameterService

public IParameterService getParameterService()

getSymmetricDialect

public ISymmetricDialect getSymmetricDialect()

getTablePrefix

public String getTablePrefix()

close

protected void close(ISqlTransaction transaction)

toNodeIds

protected Set<String> toNodeIds(Set<Node> nodes)

toNodeIds

protected Set<String> toNodeIds(Set<Node> nodes,
 Set<String> nodeIds)

isCalledFromSymmetricAdminTool

protected boolean isCalledFromSymmetricAdminTool()

buildBatchWhere

protected String buildBatchWhere(List<String> nodeIds,
 List<String> channels,
 List<?> statuses,
 List<Long> loads,
 Date startAtLastUpdatedTime)

buildBatchWhereFromFilter

protected String buildBatchWhereFromFilter(List<FilterCriterion> filter)

buildBatchParams

protected Map<String,Object> buildBatchParams(List<FilterCriterion> filter)

buildBatchOrderBy

protected String buildBatchOrderBy(String orderColumn,
 String orderDirection)

sendAck

protected void sendAck(Node remote,
 Node local,
 NodeSecurity localSecurity,
 List<IncomingBatch> list,
 ITransportManager transportManager,
 String queue)
                throws IOException

Try a configured number of times to get the ACK through.

Throws:

IOException

readAcks

protected List<BatchAck> readAcks(List<OutgoingBatch> batches,
 IOutgoingWithResponseTransport transport,
 ITransportManager transportManager,
 IAcknowledgeService acknowledgeService,
 IDataExtractorService dataExtratorService)
                           throws IOException

Throws:

IOException

logOnce

protected void logOnce(String message)

isStreamClosedByClient

protected boolean isStreamClosedByClient(Exception ex)

assertNotNull

protected void assertNotNull(Object o,
 String message)

getTargetDialect

protected ISymmetricDialect getTargetDialect()

isSymmetricTable

protected boolean isSymmetricTable(String tableName)

getTargetPlatform

protected IDatabasePlatform getTargetPlatform(String tableName)

getTargetPlatform

protected IDatabasePlatform getTargetPlatform()