org.objectweb.dream.protocol.channel
Class ConnectionFactoryImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.protocol.channel.ConnectionFactoryImpl
- All Implemented Interfaces:
- ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, ConnectionFactory, BindingController, LifeCycleController
public class ConnectionFactoryImpl
- extends AbstractComponent
- implements ConnectionFactory
Implementation of ConnectionFactory
.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
firstAvailable
protected ConnectionFactoryImpl.SessionFactory firstAvailable
lastAvailable
protected ConnectionFactoryImpl.SessionFactory lastAvailable
sessionFactories
protected Map<IPExportIdentifier,ConnectionFactoryImpl.SessionFactory> sessionFactories
threadPoolManager
protected ThreadPoolManager threadPoolManager
listenTask
protected ConnectionFactoryImpl.ListenTask listenTask
connectionManagerItf
protected ConnectionManager connectionManagerItf
ConnectionFactoryImpl
public ConnectionFactoryImpl()
addServerSocket
public void addServerSocket(ServerSocket serverSocket,
IPExportIdentifier identifier)
- Description copied from interface:
ConnectionFactory
- Adds a new server socket.
- Specified by:
addServerSocket
in interface ConnectionFactory
- Parameters:
serverSocket
- the server socket.identifier
- the export identifier associated with the server socket.- See Also:
ConnectionFactory.addServerSocket(ServerSocket, IPExportIdentifier)
removeServerSocket
public void removeServerSocket(IPExportIdentifier identifier)
throws InvalidExportIdentifierException
- Description copied from interface:
ConnectionFactory
- Removes and closes the server socket associated with the given identifier.
- Specified by:
removeServerSocket
in interface ConnectionFactory
- Parameters:
identifier
- an identifier of a previously added server socket.
- Throws:
InvalidExportIdentifierException
- if the given export identifier is
unknown.- See Also:
ConnectionFactory.removeServerSocket(IPExportIdentifier)
setAvailable
protected void setAvailable(ConnectionFactoryImpl.SessionFactory session)
getAvailable
protected ConnectionFactoryImpl.SessionFactory getAvailable()
listFc
public String[] listFc()
- Specified by:
listFc
in interface BindingController
- See Also:
BindingController.listFc()
bindFc
public void bindFc(String clientItfName,
Object serverItf)
throws NoSuchInterfaceException,
IllegalBindingException,
IllegalLifeCycleException
- Specified by:
bindFc
in interface BindingController
- Overrides:
bindFc
in class AbstractComponent
- Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
- See Also:
AbstractComponent.bindFc(String, Object)
beforeFirstStart
protected void beforeFirstStart(Component componentItf)
throws IllegalLifeCycleException
- Overrides:
beforeFirstStart
in class AbstractComponent
- Throws:
IllegalLifeCycleException
- See Also:
AbstractComponent.beforeFirstStart(Component)
prepareStopFc
public void prepareStopFc()
throws IllegalLifeCycleException
- Specified by:
prepareStopFc
in interface PrepareStopLifeCycleController
- Overrides:
prepareStopFc
in class AbstractComponent
- Throws:
IllegalLifeCycleException
- See Also:
PrepareStopLifeCycleController.prepareStopFc()
Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.