org.jumpmind.symmetric.transport

Class ConcurrentConnectionManager

java.lang.Object

org.jumpmind.symmetric.transport.ConcurrentConnectionManager

All Implemented Interfaces:

IConcurrentConnectionManager

public class ConcurrentConnectionManager
extends java.lang.Object
implements IConcurrentConnectionManager

See Also:

IConcurrentConnectionManager

Nested Class Summary

Nested Classes

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

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

IConcurrentConnectionManager.ReservationType

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ConcurrentConnectionManager(IParameterService parameterService, IStatisticManager statisticManager)

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)
static java.lang.String	getReservationIdentifier(java.lang.String nodeId, java.lang.String channelId)
protected java.util.Map<java.lang.String,java.util.Date>	getReservationsByNodeId(java.lang.String urlPath)
java.lang.String[]	getWhiteList()
protected void	logConnectedTimePeriod(java.lang.String nodeId, long startMs, long endMs, java.lang.String poolId)
protected void	logTooBusyRejection(java.lang.String nodeId, java.lang.String poolId)
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)
protected void	removeTimedOutReservations(java.util.Map<java.lang.String,ConcurrentConnectionManager.Reservation> reservations)
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)
protected boolean	shouldLogTransportError(java.lang.String nodeId)

Methods inherited from class java.lang.Object

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

Field Detail

parameterService

protected IParameterService parameterService

activeReservationsByNodeByPool

protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.Reservation>> activeReservationsByNodeByPool

nodeConnectionStatistics

protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.NodeConnectionStatistics>> nodeConnectionStatistics

whiteList

protected java.util.Set<java.lang.String> whiteList

transportErrorTimeByNode

protected java.util.Map<java.lang.String,java.lang.Long> transportErrorTimeByNode

Constructor Detail

ConcurrentConnectionManager

public ConcurrentConnectionManager(IParameterService parameterService,
                                   IStatisticManager statisticManager)

Method Detail

logTooBusyRejection

protected void logTooBusyRejection(java.lang.String nodeId,
                                   java.lang.String poolId)

logConnectedTimePeriod

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

releaseConnection

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

Specified by:

releaseConnection in interface IConcurrentConnectionManager

releaseConnection

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

Specified by:

releaseConnection in interface IConcurrentConnectionManager

addToWhitelist

public void addToWhitelist(java.lang.String nodeId)

Specified by:

addToWhitelist in interface IConcurrentConnectionManager

removeFromWhiteList

public void removeFromWhiteList(java.lang.String nodeId)

Specified by:

removeFromWhiteList in interface IConcurrentConnectionManager

getWhiteList

public java.lang.String[] getWhiteList()

Specified by:

getWhiteList in interface IConcurrentConnectionManager

getReservationCount

public int getReservationCount(java.lang.String poolId)

Specified by:

getReservationCount in interface IConcurrentConnectionManager

reserveConnection

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

Specified by:

reserveConnection in interface IConcurrentConnectionManager

reserveConnection

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

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 java.util.Map<java.lang.String,java.util.Date> getPullReservationsByNodeId()

Specified by:

getPullReservationsByNodeId in interface IConcurrentConnectionManager

getPushReservationsByNodeId

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

Specified by:

getPushReservationsByNodeId in interface IConcurrentConnectionManager

getReservationsByNodeId

protected java.util.Map<java.lang.String,java.util.Date> getReservationsByNodeId(java.lang.String urlPath)

removeTimedOutReservations

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

getReservationIdentifier

public static java.lang.String getReservationIdentifier(java.lang.String nodeId,
                                                        java.lang.String channelId)

getNodeConnectionStatisticsByPoolByNodeId

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

Specified by:

getNodeConnectionStatisticsByPoolByNodeId in interface IConcurrentConnectionManager

shouldLogTransportError

protected boolean shouldLogTransportError(java.lang.String nodeId)

getActiveReservationsByNodeByPool

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

Specified by:

getActiveReservationsByNodeByPool in interface IConcurrentConnectionManager