org.jumpmind.symmetric.transport
Interface IConcurrentConnectionManager

All Known Implementing Classes:

ConcurrentConnectionManager

public interface IConcurrentConnectionManager

Nested Class Summary

static class

IConcurrentConnectionManager.ReservationType

Method Summary

void	addToWhitelist(java.lang.String nodeId)
java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.Reservation>>	getActiveReservationsByNodeByPool()
java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.NodeConnectionStatistics>>	getNodeConnectionStatisticsByPoolByNodeId()
int	getReservationCount(java.lang.String poolId)
java.lang.String[]	getWhiteList()
boolean	releaseConnection(java.lang.String nodeId, java.lang.String poolId)
void	removeFromWhiteList(java.lang.String nodeId)
boolean	reserveConnection(java.lang.String nodeId, java.lang.String poolId, IConcurrentConnectionManager.ReservationType reservationRequest)

Method Detail

reserveConnection

boolean reserveConnection(java.lang.String nodeId,
                          java.lang.String poolId,
                          IConcurrentConnectionManager.ReservationType reservationRequest)

Parameters:

nodeId -

reservationRequest - if true then hold onto reservation for the time it typically takes for a node to reconnect after the initial request. Otherwise, we know that the node has actually connected for activity.

Returns:

true if the connection has been reserved and the node is meant to proceed with its current operation.

releaseConnection

boolean releaseConnection(java.lang.String nodeId,
                          java.lang.String poolId)

getReservationCount

int getReservationCount(java.lang.String poolId)

getNodeConnectionStatisticsByPoolByNodeId

java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.NodeConnectionStatistics>> getNodeConnectionStatisticsByPoolByNodeId()

getActiveReservationsByNodeByPool

java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.Reservation>> getActiveReservationsByNodeByPool()

addToWhitelist

void addToWhitelist(java.lang.String nodeId)

getWhiteList

java.lang.String[] getWhiteList()

removeFromWhiteList

void removeFromWhiteList(java.lang.String nodeId)