Package org.jumpmind.symmetric.transport

Interface IConcurrentConnectionManager

All Known Implementing Classes:

ConcurrentConnectionManager

public interface IConcurrentConnectionManager

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	IConcurrentConnectionManager.ReservationStatus
static enum	IConcurrentConnectionManager.ReservationType

Method Summary

Modifier and Type	Method	Description
void	addToWhitelist(String nodeId)
Map<String,Map<String,ConcurrentConnectionManager.Reservation>>	getActiveReservationsByNodeByPool()
Map<String,Map<String,ConcurrentConnectionManager.NodeConnectionStatistics>>	getNodeConnectionStatisticsByPoolByNodeId()
Map<String,Date>	getPullReservationsByNodeId()
Map<String,Date>	getPushReservationsByNodeId()
int	getReservationCount(String poolId)
String[]	getWhiteList()
boolean	releaseConnection(String nodeId, String poolId)
boolean	releaseConnection(String nodeId, String channelId, String poolId)
void	removeFromWhiteList(String nodeId)
IConcurrentConnectionManager.ReservationStatus	reserveConnection(String nodeId, String channelId, String poolId, IConcurrentConnectionManager.ReservationType reservationRequest, boolean requiresExistingReservation)

Method Details

reserveConnection

IConcurrentConnectionManager.ReservationStatus reserveConnection(String nodeId,
 String channelId,
 String poolId,
 IConcurrentConnectionManager.ReservationType reservationRequest,
 boolean requiresExistingReservation)

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(String nodeId,
 String poolId)

releaseConnection

boolean releaseConnection(String nodeId,
 String channelId,
 String poolId)

getReservationCount

int getReservationCount(String poolId)

getNodeConnectionStatisticsByPoolByNodeId

Map<String,Map<String,ConcurrentConnectionManager.NodeConnectionStatistics>> getNodeConnectionStatisticsByPoolByNodeId()

getActiveReservationsByNodeByPool

Map<String,Map<String,ConcurrentConnectionManager.Reservation>> getActiveReservationsByNodeByPool()

addToWhitelist

void addToWhitelist(String nodeId)

getWhiteList

String[] getWhiteList()

removeFromWhiteList

void removeFromWhiteList(String nodeId)

getPullReservationsByNodeId

Map<String,Date> getPullReservationsByNodeId()

getPushReservationsByNodeId

Map<String,Date> getPushReservationsByNodeId()