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, LoadFilterService, MailService, MonitorService, NodeCommunicationService, NodeService, OfflinePullService, OfflinePushService, OutgoingBatchService, PurgeService, RegistrationService, RouterService, SequenceService, StatisticService, TransformService, TriggerRouterService, UpdateService

public abstract class AbstractService
extends java.lang.Object
implements IService

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log
protected IParameterService	parameterService
protected org.jumpmind.db.platform.IDatabasePlatform	platform
protected org.jumpmind.db.sql.ISqlTemplate	sqlTemplate
protected org.jumpmind.db.sql.ISqlTemplate	sqlTemplateDirty
protected ISymmetricDialect	symmetricDialect
protected java.lang.String	tablePrefix

Constructor Summary

Constructors

Constructor and Description
AbstractService(IParameterService parameterService, ISymmetricDialect symmetricDialect)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

parameterService

protected IParameterService parameterService

symmetricDialect

protected ISymmetricDialect symmetricDialect

sqlTemplate

protected org.jumpmind.db.sql.ISqlTemplate sqlTemplate

sqlTemplateDirty

protected org.jumpmind.db.sql.ISqlTemplate sqlTemplateDirty

platform

protected org.jumpmind.db.platform.IDatabasePlatform platform

tablePrefix

protected java.lang.String tablePrefix

Constructor Detail

AbstractService

public AbstractService(IParameterService parameterService,
                       ISymmetricDialect symmetricDialect)

Method Detail

maxDate

protected java.util.Date maxDate(java.util.Date... dates)

setSqlMap

protected void setSqlMap(ISqlMap sqlMap)

getJdbcTemplate

public org.jumpmind.db.sql.ISqlTemplate getJdbcTemplate()

synchronize

public void synchronize(java.lang.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(java.lang.Object value)

createSqlReplacementTokens

protected java.util.Map<java.lang.String,java.lang.String> createSqlReplacementTokens()

createSqlReplacementTokens

public static java.util.Map<java.lang.String,java.lang.String> createSqlReplacementTokens(java.lang.String tablePrefix,
                                                                                          java.lang.String quotedIdentifier,
                                                                                          org.jumpmind.db.platform.IDatabasePlatform platform)

getSql

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

Specified by:

getSql in interface IService

getParameterService

public IParameterService getParameterService()

getSymmetricDialect

public ISymmetricDialect getSymmetricDialect()

getTablePrefix

public java.lang.String getTablePrefix()

close

protected void close(org.jumpmind.db.sql.ISqlTransaction transaction)

toNodeIds

protected java.util.Set<java.lang.String> toNodeIds(java.util.Set<Node> nodes)

toNodeIds

protected java.util.Set<java.lang.String> toNodeIds(java.util.Set<Node> nodes,
                                                    java.util.Set<java.lang.String> nodeIds)

isCalledFromSymmetricAdminTool

protected boolean isCalledFromSymmetricAdminTool()

buildBatchWhere

protected java.lang.String buildBatchWhere(java.util.List<java.lang.String> nodeIds,
                                           java.util.List<java.lang.String> channels,
                                           java.util.List<?> statuses,
                                           java.util.List<java.lang.Long> loads)

sendAck

protected void sendAck(Node remote,
                       Node local,
                       NodeSecurity localSecurity,
                       java.util.List<IncomingBatch> list,
                       ITransportManager transportManager)
                throws java.io.IOException

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

Throws:

java.io.IOException

readAcks

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

Throws:

java.io.IOException

logOnce

protected void logOnce(java.lang.String message)

isStreamClosedByClient

protected boolean isStreamClosedByClient(java.lang.Exception ex)

assertNotNull

protected void assertNotNull(java.lang.Object o,
                             java.lang.String message)

getTargetDialect

protected ISymmetricDialect getTargetDialect()

isSymmetricTable

protected boolean isSymmetricTable(java.lang.String tableName)

getTargetPlatform

protected org.jumpmind.db.platform.IDatabasePlatform getTargetPlatform(java.lang.String tableName)

getTargetPlatform

protected org.jumpmind.db.platform.IDatabasePlatform getTargetPlatform()