org.jumpmind.symmetric.service

Interface INodeCommunicationService

All Known Implementing Classes:

NodeCommunicationService

public interface INodeCommunicationService

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	INodeCommunicationService.INodeCommunicationExecutor

Method Summary

Modifier and Type	Method and Description
boolean	execute(NodeCommunication nodeCommunication, RemoteNodeStatuses statuses, INodeCommunicationService.INodeCommunicationExecutor executor)
NodeCommunication	find(java.lang.String nodeId, java.lang.String channelId, NodeCommunication.CommunicationType communicationType)
int	getAvailableThreads(NodeCommunication.CommunicationType communicationType)
java.util.List<NodeCommunication>	list(NodeCommunication.CommunicationType communicationType)
java.util.Map<java.lang.String,java.lang.Integer>	parseQueueToBatchCounts(java.lang.String channelToBatchCountsString)
void	persistToTableForSnapshot()
void	stop()
void	updateBatchToSendCounts(java.lang.String nodeId, java.util.Map<java.lang.String,java.lang.Integer> batchesCountToQueues)

Method Detail

list

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

find

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

execute

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

getAvailableThreads

int getAvailableThreads(NodeCommunication.CommunicationType communicationType)

stop

void stop()

updateBatchToSendCounts

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

parseQueueToBatchCounts

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

persistToTableForSnapshot

void persistToTableForSnapshot()