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 and Description
NodeCommunicationService(IClusterService clusterService, INodeService nodeService, IParameterService parameterService, IConfigurationService configurationService, ISymmetricDialect symmetricDialect)

Method Summary

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

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

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, 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 Detail

NodeCommunicationService

public NodeCommunicationService(IClusterService clusterService,
                                INodeService nodeService,
                                IParameterService parameterService,
                                IConfigurationService configurationService,
                                ISymmetricDialect symmetricDialect)

Method Detail

persistToTableForSnapshot

public void persistToTableForSnapshot()

Specified by:

persistToTableForSnapshot in interface INodeCommunicationService

find

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

Specified by:

find in interface INodeCommunicationService

find

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

list

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

Specified by:

list in interface INodeCommunicationService

getNodeIdsWithUnsentCount

protected java.util.List<java.lang.String> getNodeIdsWithUnsentCount()

filterForChannelThreading

protected java.util.List<NodeCommunication> filterForChannelThreading(java.util.List<Node> nodesToCommunicateWith)

removeOfflineNodes

protected java.util.List<Node> removeOfflineNodes(java.util.List<Node> nodes)

getNodesToCommunicateWithOffline

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

delete

public boolean delete(NodeCommunication nodeCommunication)

save

protected void save(NodeCommunication nodeCommunication,
                    boolean force)

removeNodesWithNoBatchesToSend

protected java.util.List<NodeCommunication> removeNodesWithNoBatchesToSend(java.util.List<NodeCommunication> nodeCommunications)

getExecutor

protected java.util.concurrent.ThreadPoolExecutor getExecutor(NodeCommunication.CommunicationType communicationType)

getExecutor

protected java.util.concurrent.ThreadPoolExecutor getExecutor(NodeCommunication.CommunicationType communicationType,
                                                              java.lang.String threadChannelId)

getAvailableThreads

public int getAvailableThreads(NodeCommunication.CommunicationType communicationType)

Specified by:

getAvailableThreads in interface INodeCommunicationService

getLockTimeoutDate

protected java.util.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,
                       java.util.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(java.util.List<NodeCommunication> list,
                                      NodeCommunication.CommunicationType communicationType)

updateBatchToSendCounts

public void updateBatchToSendCounts(java.lang.String nodeId,
                                    java.util.Map<java.lang.String,java.lang.Integer> batchesCountToQueues)

Specified by:

updateBatchToSendCounts in interface INodeCommunicationService

parseQueueToBatchCounts

public java.util.Map<java.lang.String,java.lang.Integer> parseQueueToBatchCounts(java.lang.String channelToBatchCountsString)

Specified by:

parseQueueToBatchCounts in interface INodeCommunicationService