Package org.jumpmind.symmetric.transport

Class ConcurrentConnectionManager

java.lang.Object

org.jumpmind.symmetric.transport.ConcurrentConnectionManager

All Implemented Interfaces:

IConcurrentConnectionManager

public class ConcurrentConnectionManager
extends Object
implements IConcurrentConnectionManager

See Also:

• IConcurrentConnectionManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConcurrentConnectionManager.NodeConnectionStatistics
static class	ConcurrentConnectionManager.Reservation

Nested classes/interfaces inherited from interface org.jumpmind.symmetric.transport.IConcurrentConnectionManager

IConcurrentConnectionManager.ReservationStatus, IConcurrentConnectionManager.ReservationType

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String,Map<String,ConcurrentConnectionManager.Reservation>>	activeReservationsByNodeByPool
protected Map<String,Map<String,ConcurrentConnectionManager.NodeConnectionStatistics>>	nodeConnectionStatistics
protected IParameterService	parameterService
protected Map<String,Long>	transportErrorTimeByNode
protected Set<String>	whiteList

Constructor Summary

Constructors

Constructor	Description
ConcurrentConnectionManager(IParameterService parameterService, IStatisticManager statisticManager)

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)
static String	getReservationIdentifier(String nodeId, String channelId)
protected Map<String,Date>	getReservationsByNodeId(String urlPath)
String[]	getWhiteList()
protected void	logConnectedTimePeriod(String nodeId, long startMs, long endMs, String poolId)
protected void	logTooBusyRejection(String nodeId, String poolId)
boolean	releaseConnection(String nodeId, String poolId)
boolean	releaseConnection(String nodeId, String channelId, String poolId)
void	removeFromWhiteList(String nodeId)
protected void	removeTimedOutReservations(Map<String,ConcurrentConnectionManager.Reservation> reservations)
IConcurrentConnectionManager.ReservationStatus	reserveConnection(String nodeId, String channelId, String poolId, IConcurrentConnectionManager.ReservationType reservationRequest, boolean requiresExistingReservation)
protected boolean	shouldLogTransportError(String nodeId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

parameterService

protected IParameterService parameterService

activeReservationsByNodeByPool

protected Map<String,Map<String,ConcurrentConnectionManager.Reservation>> activeReservationsByNodeByPool

nodeConnectionStatistics

protected Map<String,Map<String,ConcurrentConnectionManager.NodeConnectionStatistics>> nodeConnectionStatistics

whiteList

protected Set<String> whiteList

transportErrorTimeByNode

protected Map<String,Long> transportErrorTimeByNode

Constructor Details

ConcurrentConnectionManager

public ConcurrentConnectionManager(IParameterService parameterService,
 IStatisticManager statisticManager)

Method Details

logTooBusyRejection

protected void logTooBusyRejection(String nodeId,
 String poolId)

logConnectedTimePeriod

protected void logConnectedTimePeriod(String nodeId,
 long startMs,
 long endMs,
 String poolId)

releaseConnection

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

Specified by:

releaseConnection in interface IConcurrentConnectionManager

releaseConnection

public boolean releaseConnection(String nodeId,
 String poolId)

Specified by:

releaseConnection in interface IConcurrentConnectionManager

addToWhitelist

public void addToWhitelist(String nodeId)

Specified by:

addToWhitelist in interface IConcurrentConnectionManager

removeFromWhiteList

public void removeFromWhiteList(String nodeId)

Specified by:

removeFromWhiteList in interface IConcurrentConnectionManager

getWhiteList

public String[] getWhiteList()

Specified by:

getWhiteList in interface IConcurrentConnectionManager

getReservationCount

public int getReservationCount(String poolId)

Specified by:

getReservationCount in interface IConcurrentConnectionManager

reserveConnection

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

Specified by:

reserveConnection in interface IConcurrentConnectionManager

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.

getPullReservationsByNodeId

public Map<String,Date> getPullReservationsByNodeId()

Specified by:

getPullReservationsByNodeId in interface IConcurrentConnectionManager

getPushReservationsByNodeId

public Map<String,Date> getPushReservationsByNodeId()

Specified by:

getPushReservationsByNodeId in interface IConcurrentConnectionManager

getReservationsByNodeId

protected Map<String,Date> getReservationsByNodeId(String urlPath)

removeTimedOutReservations

protected void removeTimedOutReservations(Map<String,ConcurrentConnectionManager.Reservation> reservations)

getReservationIdentifier

public static String getReservationIdentifier(String nodeId,
 String channelId)

getNodeConnectionStatisticsByPoolByNodeId

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

Specified by:

getNodeConnectionStatisticsByPoolByNodeId in interface IConcurrentConnectionManager

shouldLogTransportError

protected boolean shouldLogTransportError(String nodeId)

getActiveReservationsByNodeByPool

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

Specified by:

getActiveReservationsByNodeByPool in interface IConcurrentConnectionManager