org.jumpmind.symmetric.transport

Interface IConcurrentConnectionManager

All Known Implementing Classes:

ConcurrentConnectionManager

public interface IConcurrentConnectionManager

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IConcurrentConnectionManager.ReservationType

Method Summary

Modifier and Type	Method and Description
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()
java.util.Map<java.lang.String,java.util.Date>	getPullReservationsByNodeId()
java.util.Map<java.lang.String,java.util.Date>	getPushReservationsByNodeId()
int	getReservationCount(java.lang.String poolId)
java.lang.String[]	getWhiteList()
boolean	releaseConnection(java.lang.String nodeId, java.lang.String poolId)
boolean	releaseConnection(java.lang.String nodeId, java.lang.String channelId, java.lang.String poolId)
void	removeFromWhiteList(java.lang.String nodeId)
boolean	reserveConnection(java.lang.String nodeId, java.lang.String poolId, IConcurrentConnectionManager.ReservationType reservationRequest)
boolean	reserveConnection(java.lang.String nodeId, java.lang.String channelId, 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.

reserveConnection

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

releaseConnection

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

releaseConnection

boolean releaseConnection(java.lang.String nodeId,
                          java.lang.String channelId,
                          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)

getPullReservationsByNodeId

java.util.Map<java.lang.String,java.util.Date> getPullReservationsByNodeId()

getPushReservationsByNodeId

java.util.Map<java.lang.String,java.util.Date> getPushReservationsByNodeId()