public class ConnectionManager extends ContainerLifeCycle
AbstractLifeCycle.AbstractLifeCycleListener
Container.InheritedListener, Container.Listener
LifeCycle.Listener
Constructor and Description |
---|
ConnectionManager(ByteBufferPool bufferPool,
Executor executor,
Scheduler scheduler,
SslContextFactory sslContextFactory,
WebSocketPolicy policy) |
Modifier and Type | Method and Description |
---|---|
void |
addClient(WebSocketClient client) |
FutureCallback<UpgradeResponse> |
connectPhysical(DefaultWebSocketClient client) |
FutureCallback<UpgradeResponse> |
connectVirtual(WebSocketClient client) |
protected void |
doStop()
Stops the managed lifecycle beans in the reverse order they were added.
|
Collection<WebSocketClient> |
getClients() |
WebSocketClientSelectorManager |
getSelector() |
static InetSocketAddress |
toSocketAddress(URI uri) |
addBean, addBean, addBean, contains, destroy, doStart, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, setStopTimeout, unmanage, updateBean, updateBeans
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
public ConnectionManager(ByteBufferPool bufferPool, Executor executor, Scheduler scheduler, SslContextFactory sslContextFactory, WebSocketPolicy policy)
public static InetSocketAddress toSocketAddress(URI uri)
public void addClient(WebSocketClient client)
public FutureCallback<UpgradeResponse> connectPhysical(DefaultWebSocketClient client) throws IOException
IOException
public FutureCallback<UpgradeResponse> connectVirtual(WebSocketClient client)
protected void doStop() throws Exception
ContainerLifeCycle
doStop
in class ContainerLifeCycle
Exception
public Collection<WebSocketClient> getClients()
public WebSocketClientSelectorManager getSelector()
Copyright © 1995-2012 Mort Bay Consulting. All Rights Reserved.