Package org.jumpmind.symmetric.service.impl

Class OfflinePullService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.OfflinePullService

All Implemented Interfaces:

INodeCommunicationService.INodeCommunicationExecutor, IOfflinePullService, IService

public class OfflinePullService
extends AbstractService
implements IOfflinePullService, INodeCommunicationService.INodeCommunicationExecutor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OfflinePullService.FileIncomingFilter

Field Summary

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

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

Constructor Summary

Constructors

Constructor	Description
OfflinePullService(IParameterService parameterService, ISymmetricDialect symmetricDialect, INodeService nodeService, IDataLoaderService dataLoaderService, IClusterService clusterService, INodeCommunicationService nodeCommunicationService, IConfigurationService configurationService, IExtensionService extensionService, ITransportManager transportManager)

Method Summary

Modifier and Type	Method	Description
void	execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
RemoteNodeStatuses	pullData(boolean force)

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

OfflinePullService

public OfflinePullService(IParameterService parameterService,
 ISymmetricDialect symmetricDialect,
 INodeService nodeService,
 IDataLoaderService dataLoaderService,
 IClusterService clusterService,
 INodeCommunicationService nodeCommunicationService,
 IConfigurationService configurationService,
 IExtensionService extensionService,
 ITransportManager transportManager)

Method Details

pullData

public RemoteNodeStatuses pullData(boolean force)

Specified by:

pullData in interface IOfflinePullService

execute

public void execute(NodeCommunication nodeCommunication,
 RemoteNodeStatus status)

Specified by:

execute in interface INodeCommunicationService.INodeCommunicationExecutor