Package org.jumpmind.symmetric.service.impl

Class PushService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.AbstractOfflineDetectorService

org.jumpmind.symmetric.service.impl.PushService

All Implemented Interfaces:

INodeCommunicationService.INodeCommunicationExecutor, IOfflineDetectorService, IPushService, IService

public class PushService
extends AbstractOfflineDetectorService
implements IPushService, INodeCommunicationService.INodeCommunicationExecutor

See Also:

• IPushService

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
PushService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
void	execute(NodeCommunication nodeCommunication, RemoteNodeStatus status)
protected List<NodeCommunication>	filterForReadyQueues(List<NodeCommunication> nodes)
Map<String,Date>	getStartTimesOfNodesBeingPushedTo()
RemoteNodeStatuses	pushData(boolean force)	Attempt to push data, if any has been captured, to nodes that the captured data is targeted for.

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

PushService

public PushService(ISymmetricEngine engine)

Method Details

getStartTimesOfNodesBeingPushedTo

public Map<String,Date> getStartTimesOfNodesBeingPushedTo()

Specified by:

getStartTimesOfNodesBeingPushedTo in interface IPushService

pushData

public RemoteNodeStatuses pushData(boolean force)

Description copied from interface: IPushService

Attempt to push data, if any has been captured, to nodes that the captured data is targeted for.

Specified by:

pushData in interface IPushService

Parameters:

force - TODO

Returns:

RemoteNodeStatuses the status of the push attempt(s)

filterForReadyQueues

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

execute

public void execute(NodeCommunication nodeCommunication,
 RemoteNodeStatus status)

Specified by:

execute in interface INodeCommunicationService.INodeCommunicationExecutor