public class PullService extends AbstractOfflineDetectorService implements IPullService, INodeCommunicationService.INodeCommunicationExecutor
IPullServiceextensionServicelog, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
PullService(IParameterService parameterService,
ISymmetricDialect symmetricDialect,
INodeService nodeService,
IDataLoaderService dataLoaderService,
IRegistrationService registrationService,
IClusterService clusterService,
INodeCommunicationService nodeCommunicationService,
IConfigurationService configurationService,
IExtensionService extensionService,
IStatisticManager statisticManager) |
| Modifier and Type | Method and Description |
|---|---|
void |
execute(NodeCommunication nodeCommunication,
RemoteNodeStatus status) |
RemoteNodeStatus |
pullConfigData(boolean force) |
RemoteNodeStatuses |
pullData(boolean force) |
fireOffline, fireOnline, getHttpException, getRootCause, isAuthenticationExpired, isBusy, isNoReservation, isNotAuthenticated, isOffline, isRegistrationNotOpen, isRegistrationPending, isRegistrationRequired, isServiceUnavailable, isSyncDisabled, shouldLogTransportErrorassertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic PullService(IParameterService parameterService, ISymmetricDialect symmetricDialect, INodeService nodeService, IDataLoaderService dataLoaderService, IRegistrationService registrationService, IClusterService clusterService, INodeCommunicationService nodeCommunicationService, IConfigurationService configurationService, IExtensionService extensionService, IStatisticManager statisticManager)
public RemoteNodeStatuses pullData(boolean force)
pullData in interface IPullServicepublic void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
execute in interface INodeCommunicationService.INodeCommunicationExecutorpublic RemoteNodeStatus pullConfigData(boolean force)
pullConfigData in interface IPullService