Package 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	Description
PullService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
void	execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
protected List<NodeCommunication>	filterForReadyQueues(List<NodeCommunication> nodes)
RemoteNodeStatus	pullConfigData(boolean force)
RemoteNodeStatuses	pullData(boolean force)

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

fireOffline, fireOnline, getExceptionMessage, getHttpException, is, isAuthenticationExpired, isBusy, isDuplicateConnection, isInitialLoadPending, isNoReservation, isNotAuthenticated, isOffline, isRegistrationNotOpen, isRegistrationPending, isRegistrationRequired, isServiceNotReady, isServiceUnavailable, isSyncDisabled, logTransportMessage, shouldLogTransportError

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

PullService

public PullService(ISymmetricEngine engine)

Method Details

pullData

public RemoteNodeStatuses pullData(boolean force)

Specified by:

pullData in interface IPullService

filterForReadyQueues

protected List<NodeCommunication> filterForReadyQueues(List<NodeCommunication> nodes)

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