Package org.jumpmind.symmetric.service

Interface INodeCommunicationService

All Known Implementing Classes:

NodeCommunicationService

public interface INodeCommunicationService

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	INodeCommunicationService.INodeCommunicationExecutor

Method Summary

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

Method Details

list

List<NodeCommunication> list(NodeCommunication.CommunicationType communicationType)

listAll

List<NodeCommunication> listAll(NodeCommunication.CommunicationType communicationType)

find

NodeCommunication find(String nodeId,
 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(String nodeId,
 Map<String,Integer> batchesCountToQueues)

parseQueueToBatchCounts

Map<String,Integer> parseQueueToBatchCounts(String channelToBatchCountsString)

persistToTableForSnapshot

void persistToTableForSnapshot()