org.activeio.oneport
Class OnePortAsyncChannelServer
java.lang.Object
org.activeio.FilterAsyncChannelServer
org.activeio.oneport.OnePortAsyncChannelServer
- All Implemented Interfaces:
- AcceptListener, AsyncChannelServer, Channel, ChannelServer, Disposable, Service
public final class OnePortAsyncChannelServer
- extends FilterAsyncChannelServer
Allows multiple protocols share a single ChannelServer. All protocols sharing the server
must have a distinct magic number at the beginning of the client's request.
TODO: handle the case where a client opens a connection but sends no data down the stream. We need
to timeout that client.
- Version:
- $Revision$
OnePortAsyncChannelServer
public OnePortAsyncChannelServer(AsyncChannelServer server)
throws IOException
- Throws:
IOException
setAcceptListener
public void setAcceptListener(AcceptListener acceptListener)
- Description copied from interface:
AsyncChannelServer
- Registers an AcceptListener which is notified of accepted channels.
- Specified by:
setAcceptListener
in interface AsyncChannelServer
- Overrides:
setAcceptListener
in class FilterAsyncChannelServer
bindAsyncChannel
public AsyncChannelServer bindAsyncChannel(ProtocolRecognizer recognizer)
throws IOException
- Throws:
IOException
Copyright © -2009 The ActiveIO Project. All Rights Reserved.