Package org.jumpmind.symmetric.service.impl

Class NodeCommunicationService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.NodeCommunicationService

All Implemented Interfaces:

INodeCommunicationService, IService

public class NodeCommunicationService
extends AbstractService
implements INodeCommunicationService

Nested Class Summary

Nested classes/interfaces inherited from interface org.jumpmind.symmetric.service.INodeCommunicationService

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

Method Summary

Modifier and Type	Method	Description
boolean	delete(NodeCommunication nodeCommunication)
boolean	execute(NodeCommunication nodeCommunication, RemoteNodeStatuses statuses, INodeCommunicationService.INodeCommunicationExecutor executor)
protected List<NodeCommunication>	filterForChannelThreading(List<Node> nodesToCommunicateWith, NodeCommunication.CommunicationType communicationType, IReloadQueueThreadAssigner extension)
NodeCommunication	find(String nodeId, String queue, NodeCommunication.CommunicationType communicationType)
protected List<NodeCommunication>	find(NodeCommunication.CommunicationType communicationType)
int	getAvailableThreads(NodeCommunication.CommunicationType communicationType)
protected ThreadPoolExecutor	getExecutor(NodeCommunication.CommunicationType communicationType)
protected ThreadPoolExecutor	getExecutor(NodeCommunication.CommunicationType communicationType, String threadChannelId)
protected Date	getLockTimeoutDate(NodeCommunication.CommunicationType communicationType)
protected List<String>	getNodeIdsWithUnsentCount()
protected List<Node>	getNodesToCommunicateWithOffline(NodeCommunication.CommunicationType communicationType)
List<NodeCommunication>	list(NodeCommunication.CommunicationType communicationType)
protected List<NodeCommunication>	list(NodeCommunication.CommunicationType communicationType, boolean onlyNodesWithChanges)
List<NodeCommunication>	listAll(NodeCommunication.CommunicationType communicationType)
protected boolean	lock(NodeCommunication nodeCommunication, Date lockTime)
protected void	multiplyNodeCommunicationByQueues(Node node, List<NodeCommunication> nodeCommunications, HashSet<String> queues)
Map<String,Integer>	parseQueueToBatchCounts(String channelToBatchCountsString)
void	persistToTableForSnapshot()
protected void	removeInvalidQueues(NodeCommunication.CommunicationType communicationType, List<NodeCommunication> communicationRows, Map<String,NodeCommunication> nodesToCommunicateWithListMap, IReloadQueueThreadAssigner extension)
protected List<NodeCommunication>	removeNodesWithNoBatchesToSend(List<NodeCommunication> nodeCommunications)
protected List<Node>	removeOfflineNodes(List<Node> nodes)
protected void	save(NodeCommunication nodeCommunication, boolean force)
protected void	sortNodeCommunications(List<NodeCommunication> list, NodeCommunication.CommunicationType communicationType)
void	stop()
protected void	unlock(NodeCommunication nodeCommunication, boolean failed, long ts)
void	updateBatchToSendCounts(String nodeId, Map<String,Integer> batchesCountToQueues)

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

NodeCommunicationService

public NodeCommunicationService(ISymmetricEngine engine)

Method Details

persistToTableForSnapshot

public void persistToTableForSnapshot()

Specified by:

persistToTableForSnapshot in interface INodeCommunicationService

find

public NodeCommunication find(String nodeId,
 String queue,
 NodeCommunication.CommunicationType communicationType)

Specified by:

find in interface INodeCommunicationService

find

protected List<NodeCommunication> find(NodeCommunication.CommunicationType communicationType)

list

public List<NodeCommunication> list(NodeCommunication.CommunicationType communicationType)

Specified by:

list in interface INodeCommunicationService

listAll

public List<NodeCommunication> listAll(NodeCommunication.CommunicationType communicationType)

Specified by:

listAll in interface INodeCommunicationService

list

protected List<NodeCommunication> list(NodeCommunication.CommunicationType communicationType,
 boolean onlyNodesWithChanges)

removeInvalidQueues

protected void removeInvalidQueues(NodeCommunication.CommunicationType communicationType,
 List<NodeCommunication> communicationRows,
 Map<String,NodeCommunication> nodesToCommunicateWithListMap,
 IReloadQueueThreadAssigner extension)

getNodeIdsWithUnsentCount

protected List<String> getNodeIdsWithUnsentCount()

filterForChannelThreading

protected List<NodeCommunication> filterForChannelThreading(List<Node> nodesToCommunicateWith,
 NodeCommunication.CommunicationType communicationType,
 IReloadQueueThreadAssigner extension)

multiplyNodeCommunicationByQueues

protected void multiplyNodeCommunicationByQueues(Node node,
 List<NodeCommunication> nodeCommunications,
 HashSet<String> queues)

removeOfflineNodes

protected List<Node> removeOfflineNodes(List<Node> nodes)

getNodesToCommunicateWithOffline

protected List<Node> getNodesToCommunicateWithOffline(NodeCommunication.CommunicationType communicationType)

delete

public boolean delete(NodeCommunication nodeCommunication)

save

protected void save(NodeCommunication nodeCommunication,
 boolean force)

removeNodesWithNoBatchesToSend

protected List<NodeCommunication> removeNodesWithNoBatchesToSend(List<NodeCommunication> nodeCommunications)

getExecutor

protected ThreadPoolExecutor getExecutor(NodeCommunication.CommunicationType communicationType)

getExecutor

protected ThreadPoolExecutor getExecutor(NodeCommunication.CommunicationType communicationType,
 String threadChannelId)

getAvailableThreads

public int getAvailableThreads(NodeCommunication.CommunicationType communicationType)

Specified by:

getAvailableThreads in interface INodeCommunicationService

getLockTimeoutDate

protected Date getLockTimeoutDate(NodeCommunication.CommunicationType communicationType)

execute

public boolean execute(NodeCommunication nodeCommunication,
 RemoteNodeStatuses statuses,
 INodeCommunicationService.INodeCommunicationExecutor executor)

Specified by:

execute in interface INodeCommunicationService

lock

protected boolean lock(NodeCommunication nodeCommunication,
 Date lockTime)

unlock

protected void unlock(NodeCommunication nodeCommunication,
 boolean failed,
 long ts)

stop

public void stop()

Specified by:

stop in interface INodeCommunicationService

sortNodeCommunications

protected void sortNodeCommunications(List<NodeCommunication> list,
 NodeCommunication.CommunicationType communicationType)

updateBatchToSendCounts

public void updateBatchToSendCounts(String nodeId,
 Map<String,Integer> batchesCountToQueues)

Specified by:

updateBatchToSendCounts in interface INodeCommunicationService

parseQueueToBatchCounts

public Map<String,Integer> parseQueueToBatchCounts(String channelToBatchCountsString)

Specified by:

parseQueueToBatchCounts in interface INodeCommunicationService