org.mobicents.media.server
Class EndpointImpl

java.lang.Object
  org.mobicents.media.server.EndpointImpl

All Implemented Interfaces:

java.io.Serializable, org.mobicents.media.server.spi.Endpoint

public class EndpointImpl
extends java.lang.Object
implements org.mobicents.media.server.spi.Endpoint

Author:

kulikov

See Also:

Serialized Form

Field Summary

protected java.util.HashMap<java.lang.String,org.mobicents.media.server.spi.Connection>	connections Holder for created connections
protected java.util.concurrent.locks.ReentrantLock	state

Fields inherited from interface org.mobicents.media.server.spi.Endpoint

DTMF, G729, GSM, LINEAR_AUDIO, PCMA, PCMU, SPEEX

Constructor Summary

EndpointImpl()

EndpointImpl(java.lang.String localName)

Method Summary

void	addConnectionListener(org.mobicents.media.server.spi.ConnectionListener listener)
void	addNotificationListener(org.mobicents.media.server.spi.NotificationListener listener)
org.mobicents.media.server.spi.Connection	createConnection(org.mobicents.media.server.spi.ConnectionMode mode)
org.mobicents.media.server.spi.Connection	createLocalConnection(org.mobicents.media.server.spi.ConnectionMode mode)
protected Channel	createRxChannel(org.mobicents.media.server.spi.Connection connection)
protected Channel	createTxChannel(org.mobicents.media.server.spi.Connection connection)
void	deleteAllConnections() (Non Java-doc).
void	deleteConnection(java.lang.String connectionID)
org.mobicents.media.Component	getComponent(int resourceID)
org.mobicents.media.Component	getComponent(java.lang.String name)
org.mobicents.media.server.spi.Connection	getConnection(java.lang.String connectionID)
ConnectionFactory	getConnectionFactory()
java.util.Collection<org.mobicents.media.server.spi.Connection>	getConnections()
org.mobicents.media.ComponentFactory	getGroupFactory()
protected int	getIndex() Calculates index of the new connection.
java.lang.String	getLocalName()
java.util.Hashtable<java.lang.String,RtpFactory>	getRtpFactory()
protected javax.sdp.SdpFactory	getSdpFactory()
org.mobicents.media.MediaSink	getSink()
org.mobicents.media.ComponentFactory	getSinkFactory()
org.mobicents.media.MediaSource	getSource()
org.mobicents.media.ComponentFactory	getSourceFactory()
java.lang.String[]	getSupportedPackages()
org.mobicents.media.server.spi.Timer	getTimer()
boolean	hasConnections()
boolean	isInUse()
protected void	releaseRxChannel(Channel channel)
protected void	releaseTxChannel(Channel channel)
void	removeConnectionListener(org.mobicents.media.server.spi.ConnectionListener listener)
void	removeNotificationListener(org.mobicents.media.server.spi.NotificationListener listener)
void	setConnectionFactory(ConnectionFactory connectionFactory)
void	setGroupFactory(org.mobicents.media.ComponentFactory groupFactory)
void	setInUse(boolean inUse)
void	setLocalName(java.lang.String localName)
void	setRtpFactory(java.util.Hashtable<java.lang.String,RtpFactory> rtpFactory)
void	setSinkFactory(org.mobicents.media.ComponentFactory sinkFactory)
void	setSourceFactory(org.mobicents.media.ComponentFactory sourceFactory)
void	setTimer(org.mobicents.media.server.spi.Timer timer)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

connections

protected transient java.util.HashMap<java.lang.String,org.mobicents.media.server.spi.Connection> connections

Holder for created connections

state

protected java.util.concurrent.locks.ReentrantLock state

Constructor Detail

EndpointImpl

public EndpointImpl()

EndpointImpl

public EndpointImpl(java.lang.String localName)

Method Detail

getLocalName

public java.lang.String getLocalName()

Specified by:

getLocalName in interface org.mobicents.media.server.spi.Endpoint

setLocalName

public void setLocalName(java.lang.String localName)

getSink

public org.mobicents.media.MediaSink getSink()

getSource

public org.mobicents.media.MediaSource getSource()

getIndex

protected int getIndex()

Calculates index of the new connection. The connection uses this method to ask endpoint for new lowerest index. The index is unique withing endpoint but it is not used as connection identifier outside of the endpoint.

Returns:

the lowerest available integer value.

start

public void start()
           throws org.mobicents.media.server.spi.ResourceUnavailableException

Specified by:

start in interface org.mobicents.media.server.spi.Endpoint

Throws:

org.mobicents.media.server.spi.ResourceUnavailableException

stop

public void stop()

Specified by:

stop in interface org.mobicents.media.server.spi.Endpoint

getSdpFactory

protected javax.sdp.SdpFactory getSdpFactory()

getTimer

public org.mobicents.media.server.spi.Timer getTimer()

Specified by:

getTimer in interface org.mobicents.media.server.spi.Endpoint

setTimer

public void setTimer(org.mobicents.media.server.spi.Timer timer)

Specified by:

setTimer in interface org.mobicents.media.server.spi.Endpoint

setSourceFactory

public void setSourceFactory(org.mobicents.media.ComponentFactory sourceFactory)

getSourceFactory

public org.mobicents.media.ComponentFactory getSourceFactory()

setSinkFactory

public void setSinkFactory(org.mobicents.media.ComponentFactory sinkFactory)

getSinkFactory

public org.mobicents.media.ComponentFactory getSinkFactory()

getGroupFactory

public org.mobicents.media.ComponentFactory getGroupFactory()

setGroupFactory

public void setGroupFactory(org.mobicents.media.ComponentFactory groupFactory)

getConnectionFactory

public ConnectionFactory getConnectionFactory()

setConnectionFactory

public void setConnectionFactory(ConnectionFactory connectionFactory)

setRtpFactory

public void setRtpFactory(java.util.Hashtable<java.lang.String,RtpFactory> rtpFactory)

getRtpFactory

public java.util.Hashtable<java.lang.String,RtpFactory> getRtpFactory()

createRxChannel

protected Channel createRxChannel(org.mobicents.media.server.spi.Connection connection)
                           throws org.mobicents.media.server.spi.ResourceUnavailableException

Throws:

org.mobicents.media.server.spi.ResourceUnavailableException

releaseRxChannel

protected void releaseRxChannel(Channel channel)

createTxChannel

protected Channel createTxChannel(org.mobicents.media.server.spi.Connection connection)
                           throws org.mobicents.media.server.spi.ResourceUnavailableException

Throws:

org.mobicents.media.server.spi.ResourceUnavailableException

releaseTxChannel

protected void releaseTxChannel(Channel channel)

getConnections

public java.util.Collection<org.mobicents.media.server.spi.Connection> getConnections()

createConnection

public org.mobicents.media.server.spi.Connection createConnection(org.mobicents.media.server.spi.ConnectionMode mode)
                                                           throws org.mobicents.media.server.spi.TooManyConnectionsException,
                                                                  org.mobicents.media.server.spi.ResourceUnavailableException

Specified by:

createConnection in interface org.mobicents.media.server.spi.Endpoint

Throws:

org.mobicents.media.server.spi.TooManyConnectionsException

org.mobicents.media.server.spi.ResourceUnavailableException

createLocalConnection

public org.mobicents.media.server.spi.Connection createLocalConnection(org.mobicents.media.server.spi.ConnectionMode mode)
                                                                throws org.mobicents.media.server.spi.TooManyConnectionsException,
                                                                       org.mobicents.media.server.spi.ResourceUnavailableException

Specified by:

createLocalConnection in interface org.mobicents.media.server.spi.Endpoint

Throws:

org.mobicents.media.server.spi.TooManyConnectionsException

org.mobicents.media.server.spi.ResourceUnavailableException

deleteConnection

public void deleteConnection(java.lang.String connectionID)

Specified by:

deleteConnection in interface org.mobicents.media.server.spi.Endpoint

deleteAllConnections

public void deleteAllConnections()

(Non Java-doc).

Specified by:

deleteAllConnections in interface org.mobicents.media.server.spi.Endpoint

See Also:

Endpoint.deleteAllConnections();

hasConnections

public boolean hasConnections()

Specified by:

hasConnections in interface org.mobicents.media.server.spi.Endpoint

isInUse

public boolean isInUse()

Specified by:

isInUse in interface org.mobicents.media.server.spi.Endpoint

setInUse

public void setInUse(boolean inUse)

Specified by:

setInUse in interface org.mobicents.media.server.spi.Endpoint

addNotificationListener

public void addNotificationListener(org.mobicents.media.server.spi.NotificationListener listener)

Specified by:

addNotificationListener in interface org.mobicents.media.server.spi.Endpoint

removeNotificationListener

public void removeNotificationListener(org.mobicents.media.server.spi.NotificationListener listener)

Specified by:

removeNotificationListener in interface org.mobicents.media.server.spi.Endpoint

addConnectionListener

public void addConnectionListener(org.mobicents.media.server.spi.ConnectionListener listener)

Specified by:

addConnectionListener in interface org.mobicents.media.server.spi.Endpoint

removeConnectionListener

public void removeConnectionListener(org.mobicents.media.server.spi.ConnectionListener listener)

Specified by:

removeConnectionListener in interface org.mobicents.media.server.spi.Endpoint

getSupportedPackages

public java.lang.String[] getSupportedPackages()

getConnection

public org.mobicents.media.server.spi.Connection getConnection(java.lang.String connectionID)

Specified by:

getConnection in interface org.mobicents.media.server.spi.Endpoint

getComponent

public org.mobicents.media.Component getComponent(java.lang.String name)

Specified by:

getComponent in interface org.mobicents.media.server.spi.Endpoint

getComponent

public org.mobicents.media.Component getComponent(int resourceID)

Specified by:

getComponent in interface org.mobicents.media.server.spi.Endpoint