Package org.red5.server.net.rtmp

Class RTMPConnManager

java.lang.Object

org.red5.server.net.rtmp.RTMPConnManager

All Implemented Interfaces:

IConnectionManager<RTMPConnection>, Aware, DisposableBean, ApplicationContextAware

public class RTMPConnManager
extends Object
implements IConnectionManager<RTMPConnection>, ApplicationContextAware, DisposableBean

Responsible for management and creation of RTMP based connections.

Author:

The Red5 Project

Field Summary

Fields

Modifier and Type	Field	Description
protected static ApplicationContext	applicationContext
protected ConcurrentMap<String,RTMPConnection>	connMap
protected AtomicInteger	conns
protected boolean	debug
private ScheduledExecutorService	executor
protected static IConnectionManager<RTMPConnection>	instance
private static final org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
RTMPConnManager()

Method Summary

Modifier and Type	Method	Description
RTMPConnection	createConnection(Class<?> connCls)	Creates a connection based on the given type class.
RTMPConnection	createConnection(Class<?> connCls, String sessionId)	Creates a connection of the type specified with associated session id.
RTMPConnection	createConnectionInstance(Class<?> cls)	Creates a connection instance based on the supplied type.
void	destroy()
Collection<RTMPConnection>	getAllConnections()	Returns all the current connections.
RTMPConnection	getConnection(int clientId)	Returns a connection for a given client id.
RTMPConnection	getConnectionBySessionId(String sessionId)	Returns a connection for a given session id.
static IConnectionManager<RTMPConnection>	getInstance()
RTMPConnection	removeConnection(int clientId)	Removes a connection matching the client id specified.
RTMPConnection	removeConnection(String sessionId)	Removes a connection by the given sessionId.
Collection<RTMPConnection>	removeConnections()	Removes all the connections from the set.
void	setApplicationContext(ApplicationContext applicationContext)
void	setConnection(RTMPConnection conn)	Adds a connection.
void	setDebug(boolean debug)

Methods inherited from class java.lang.Object

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

Field Details

log

private static final org.slf4j.Logger log

applicationContext

protected static ApplicationContext applicationContext

executor

private ScheduledExecutorService executor

connMap

protected ConcurrentMap<String,RTMPConnection> connMap

conns

protected AtomicInteger conns

instance

protected static IConnectionManager<RTMPConnection> instance

debug

protected boolean debug

Constructor Details

RTMPConnManager

public RTMPConnManager()

Method Details

getInstance

public static IConnectionManager<RTMPConnection> getInstance()

createConnection

public RTMPConnection createConnection(Class<?> connCls)

Creates a connection based on the given type class.

Specified by:

createConnection in interface IConnectionManager<RTMPConnection>

Parameters:

connCls - class

Returns:

connection

createConnection

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

Creates a connection of the type specified with associated session id.

Specified by:

createConnection in interface IConnectionManager<RTMPConnection>

Parameters:

connCls - class

sessionId - session id

Returns:

connection

setConnection

public void setConnection(RTMPConnection conn)

Adds a connection.

Specified by:

setConnection in interface IConnectionManager<RTMPConnection>

Parameters:

conn - connection

getConnection

public RTMPConnection getConnection(int clientId)

Returns a connection for a given client id.

Specified by:

getConnection in interface IConnectionManager<RTMPConnection>

Parameters:

clientId - client id

Returns:

connection if found and null otherwise

getConnectionBySessionId

public RTMPConnection getConnectionBySessionId(String sessionId)

Returns a connection for a given session id.

Specified by:

getConnectionBySessionId in interface IConnectionManager<RTMPConnection>

Parameters:

sessionId - session id

Returns:

connection if found and null otherwise

removeConnection

public RTMPConnection removeConnection(int clientId)

Removes a connection matching the client id specified. If found, the connection will be returned.

Specified by:

removeConnection in interface IConnectionManager<RTMPConnection>

Parameters:

clientId - client id

Returns:

connection

removeConnection

public RTMPConnection removeConnection(String sessionId)

Removes a connection by the given sessionId.

Specified by:

removeConnection in interface IConnectionManager<RTMPConnection>

Parameters:

sessionId - session id

Returns:

connection that was removed

getAllConnections

public Collection<RTMPConnection> getAllConnections()

Returns all the current connections. It doesn't remove anything.

Specified by:

getAllConnections in interface IConnectionManager<RTMPConnection>

Returns:

list of connections

removeConnections

public Collection<RTMPConnection> removeConnections()

Removes all the connections from the set.

Specified by:

removeConnections in interface IConnectionManager<RTMPConnection>

Returns:

connections

createConnectionInstance

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

Creates a connection instance based on the supplied type.

Parameters:

cls - class

Returns:

connection

Throws:

Exception - on error

setDebug

public void setDebug(boolean debug)

Parameters:

debug - the debug to set

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception