Package org.red5.client.net.rtmp

Class RTMPClientConnManager

java.lang.Object

org.red5.client.net.rtmp.RTMPClientConnManager

All Implemented Interfaces:

IConnectionManager<BaseConnection>

public class RTMPClientConnManager
extends Object
implements IConnectionManager<BaseConnection>

Responsible for management and creation of RTMP based connections.

Author:

The Red5 Project

Field Summary

Fields

Modifier and Type	Field	Description
protected ConcurrentMap<String,BaseConnection>	connMap
protected AtomicInteger	conns
protected static boolean	enableTaskExecutor
protected static IConnectionManager<BaseConnection>	instance

Constructor Summary

Constructors

Constructor	Description
RTMPClientConnManager()

Method Summary

Modifier and Type	Method	Description
BaseConnection	createConnection(Class<?> connCls)
BaseConnection	createConnection(Class<?> connCls, String sessionId)
RTMPConnection	createConnectionInstance(Class<?> cls)	Creates a connection instance based on the supplied type.
Collection<BaseConnection>	getAllConnections()
BaseConnection	getConnectionBySessionId(String sessionId)	Returns a connection for a given session id.
static IConnectionManager<BaseConnection>	getInstance()
BaseConnection	removeConnection(String sessionId)
BaseConnection	removeConnection(BaseConnection conn)
Collection<BaseConnection>	removeConnections()
static void	setEnableTaskExecutor(boolean enableTaskExecutor)
static void	setExecutorQueueCapacity(int executorQueueCapacity)
static void	setMaxHandshakeTimeout(int maxHandshakeTimeout)
static void	setMaxInactivity(int maxInactivity)
static void	setPingInterval(int pingInterval)

Methods inherited from class java.lang.Object

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

Field Details

enableTaskExecutor

protected static boolean enableTaskExecutor

instance

protected static IConnectionManager<BaseConnection> instance

connMap

protected ConcurrentMap<String,BaseConnection> connMap

conns

protected AtomicInteger conns

Constructor Details

RTMPClientConnManager

public RTMPClientConnManager()

Method Details

getInstance

public static IConnectionManager<BaseConnection> getInstance()

createConnection

public BaseConnection createConnection(Class<?> connCls)

Specified by:

createConnection in interface IConnectionManager<BaseConnection>

createConnection

public BaseConnection createConnection(Class<?> connCls,
 String sessionId)

Specified by:

createConnection in interface IConnectionManager<BaseConnection>

getConnectionBySessionId

public BaseConnection getConnectionBySessionId(String sessionId)

Returns a connection for a given session id.

Specified by:

getConnectionBySessionId in interface IConnectionManager<BaseConnection>

Parameters:

sessionId - session id

Returns:

connection if found and null otherwise

removeConnection

public BaseConnection removeConnection(BaseConnection conn)

Specified by:

removeConnection in interface IConnectionManager<BaseConnection>

removeConnection

public BaseConnection removeConnection(String sessionId)

Specified by:

removeConnection in interface IConnectionManager<BaseConnection>

getAllConnections

public Collection<BaseConnection> getAllConnections()

Specified by:

getAllConnections in interface IConnectionManager<BaseConnection>

removeConnections

public Collection<BaseConnection> removeConnections()

Specified by:

removeConnections in interface IConnectionManager<BaseConnection>

createConnectionInstance

public RTMPConnection createConnectionInstance(Class<?> cls)
                                        throws Exception

Creates a connection instance based on the supplied type.

Parameters:

cls - class

Returns:

connection

Throws:

Exception - thrown

setMaxHandshakeTimeout

public static void setMaxHandshakeTimeout(int maxHandshakeTimeout)

setMaxInactivity

public static void setMaxInactivity(int maxInactivity)

setPingInterval

public static void setPingInterval(int pingInterval)

setExecutorQueueCapacity

public static void setExecutorQueueCapacity(int executorQueueCapacity)

setEnableTaskExecutor

public static void setEnableTaskExecutor(boolean enableTaskExecutor)