org.jumpmind.symmetric.service.impl

Class PullService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.AbstractOfflineDetectorService

org.jumpmind.symmetric.service.impl.PullService

All Implemented Interfaces:

INodeCommunicationService.INodeCommunicationExecutor, IOfflineDetectorService, IPullService, IService

public class PullService
extends AbstractOfflineDetectorService
implements IPullService, INodeCommunicationService.INodeCommunicationExecutor

See Also:

IPullService

Field Summary

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

extensionService

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

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

Constructor Summary

Constructors

Constructor and Description
PullService(IParameterService parameterService, ISymmetricDialect symmetricDialect, INodeService nodeService, IDataLoaderService dataLoaderService, IRegistrationService registrationService, IClusterService clusterService, INodeCommunicationService nodeCommunicationService, IConfigurationService configurationService, IExtensionService extensionService, IStatisticManager statisticManager)

Method Summary

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

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

fireOffline, fireOnline, getHttpException, getRootCause, isAuthenticationExpired, isBusy, isNoReservation, isNotAuthenticated, isOffline, isRegistrationNotOpen, isRegistrationPending, isRegistrationRequired, isServiceUnavailable, isSyncDisabled, shouldLogTransportError

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

PullService

public PullService(IParameterService parameterService,
                   ISymmetricDialect symmetricDialect,
                   INodeService nodeService,
                   IDataLoaderService dataLoaderService,
                   IRegistrationService registrationService,
                   IClusterService clusterService,
                   INodeCommunicationService nodeCommunicationService,
                   IConfigurationService configurationService,
                   IExtensionService extensionService,
                   IStatisticManager statisticManager)

Method Detail

pullData

public RemoteNodeStatuses pullData(boolean force)

Specified by:

pullData in interface IPullService

execute

public void execute(NodeCommunication nodeCommunication,
                    RemoteNodeStatus status)

Specified by:

execute in interface INodeCommunicationService.INodeCommunicationExecutor

pullConfigData

public RemoteNodeStatus pullConfigData(boolean force)

Specified by:

pullConfigData in interface IPullService