public class PushService extends AbstractOfflineDetectorService implements IPushService, INodeCommunicationService.INodeCommunicationExecutor
IPushServiceextensionServicelog, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
PushService(IParameterService parameterService,
ISymmetricDialect symmetricDialect,
IDataExtractorService dataExtractorService,
IAcknowledgeService acknowledgeService,
ITransportManager transportManager,
INodeService nodeService,
IClusterService clusterService,
INodeCommunicationService nodeCommunicationService,
IStatisticManager statisticManager,
IConfigurationService configrationService,
IExtensionService extensionService) |
| Modifier and Type | Method and Description |
|---|---|
void |
execute(NodeCommunication nodeCommunication,
RemoteNodeStatus status) |
java.util.Map<java.lang.String,java.util.Date> |
getStartTimesOfNodesBeingPushedTo() |
RemoteNodeStatuses |
pushData(boolean force)
Attempt to push data, if any has been captured, to nodes that the
captured data is targeted for.
|
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 PushService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IDataExtractorService dataExtractorService, IAcknowledgeService acknowledgeService, ITransportManager transportManager, INodeService nodeService, IClusterService clusterService, INodeCommunicationService nodeCommunicationService, IStatisticManager statisticManager, IConfigurationService configrationService, IExtensionService extensionService)
public java.util.Map<java.lang.String,java.util.Date> getStartTimesOfNodesBeingPushedTo()
getStartTimesOfNodesBeingPushedTo in interface IPushServicepublic RemoteNodeStatuses pushData(boolean force)
IPushServicepushData in interface IPushServiceforce - TODOpublic void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
execute in interface INodeCommunicationService.INodeCommunicationExecutor