public class OfflinePushService extends AbstractService implements IOfflinePushService, INodeCommunicationService.INodeCommunicationExecutor
log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
OfflinePushService(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) |
RemoteNodeStatuses |
pushData(boolean force) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic OfflinePushService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IDataExtractorService dataExtractorService, IAcknowledgeService acknowledgeService, ITransportManager transportManager, INodeService nodeService, IClusterService clusterService, INodeCommunicationService nodeCommunicationService, IStatisticManager statisticManager, IConfigurationService configrationService, IExtensionService extensionService)
public RemoteNodeStatuses pushData(boolean force)
pushData in interface IOfflinePushServicepublic void execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
execute in interface INodeCommunicationService.INodeCommunicationExecutor