Package org.jumpmind.symmetric.service.impl

Class OfflinePushService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.OfflinePushService

All Implemented Interfaces:

INodeCommunicationService.INodeCommunicationExecutor, IOfflineDetectorService, IOfflinePushService, IService

public class OfflinePushService
extends AbstractService
implements IOfflinePushService, INodeCommunicationService.INodeCommunicationExecutor

Field Summary

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

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

Constructor Summary

Constructors

Constructor

Description

OfflinePushService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IDataExtractorService dataExtractorService, IAcknowledgeService acknowledgeService, ITransportManager transportManager, INodeService nodeService, IClusterService clusterService, INodeCommunicationService nodeCommunicationService, IStatisticManager statisticManager, IConfigurationService configrationService, IExtensionService extensionService)

Method Summary

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

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

OfflinePushService

public OfflinePushService(IParameterService parameterService,
 ISymmetricDialect symmetricDialect,
 IDataExtractorService dataExtractorService,
 IAcknowledgeService acknowledgeService,
 ITransportManager transportManager,
 INodeService nodeService,
 IClusterService clusterService,
 INodeCommunicationService nodeCommunicationService,
 IStatisticManager statisticManager,
 IConfigurationService configrationService,
 IExtensionService extensionService)

Method Details

pushData

public RemoteNodeStatuses pushData(boolean force)

Specified by:

pushData in interface IOfflinePushService

execute

public void execute(NodeCommunication nodeCommunication,
 RemoteNodeStatus status)

Specified by:

execute in interface INodeCommunicationService.INodeCommunicationExecutor