|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.remoting.transport.multiplex.MultiplexingManager
Copyright (c) 2005
Nested Class Summary | |
protected class |
MultiplexingManager.ShutdownThread
|
static class |
MultiplexingManager.StreamPair
|
Field Summary | |
static boolean |
ON_CLIENT
|
static boolean |
ON_SERVER
|
Constructor Summary | |
protected |
MultiplexingManager()
|
protected |
MultiplexingManager(java.net.InetSocketAddress address)
|
protected |
MultiplexingManager(java.net.Socket socket)
|
protected |
MultiplexingManager(java.lang.String host,
int port)
|
Method Summary | |
void |
bind(java.net.InetSocketAddress address)
|
void |
connect(java.net.InetSocketAddress address)
|
java.util.Collection |
getAllOutputStreams()
|
static MultiplexingManager |
getaManager(int port)
|
static MultiplexingManager |
getaManager(java.net.Socket socket)
|
static MultiplexingManager |
getaManagerByLocalAddress(java.net.InetSocketAddress address)
|
static MultiplexingManager |
getaManagerByRemoteAddress(java.net.InetSocketAddress address)
|
MultiplexingInputStream |
getAnInputStream(SocketId socketId,
VirtualSocket socket)
|
OutputMultiplexor |
getOutputMultiplexor()
|
java.io.OutputStream |
getOutputStreamByLocalSocket(SocketId socketId)
|
Protocol |
getProtocol()
|
int |
getReferenceCount()
|
java.net.ServerSocket |
getServerSocket()
FIXME Comment this |
java.net.Socket |
getSocket()
|
VirtualSocket |
getSocketByLocalPort(SocketId socketId)
|
void |
incrementReferences()
|
boolean |
isBound()
FIXME Comment this |
boolean |
isConnected()
FIXME Comment this |
boolean |
isConnectedRemoteSocket(SocketId socketId)
|
static boolean |
isOnClient()
|
boolean |
isServerSocketRegistered()
FIXME Comment this |
protected void |
registerByLocalAddress(java.net.InetSocketAddress address)
|
protected void |
registerByRemoteAddress(java.net.InetSocketAddress address)
|
void |
registerRemoteServerSocket()
FIXME Comment this |
void |
registerServerSocket(java.net.ServerSocket serverSocket)
|
MultiplexingManager.StreamPair |
registerSocket(VirtualSocket socket)
|
void |
releaseReference()
FIXME Comment this |
static void |
setOnClient(boolean isOnClient)
|
protected void |
setup()
|
void |
shutdown()
|
void |
unRegisterRemoteServerSocket()
FIXME Comment this |
void |
unRegisterServerSocket(java.net.ServerSocket serverSocket)
|
void |
unRegisterSocket(VirtualSocket socket)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final boolean ON_CLIENT
public static final boolean ON_SERVER
Constructor Detail |
protected MultiplexingManager()
protected MultiplexingManager(java.net.Socket socket) throws java.io.IOException
socket
-
java.io.IOException
protected MultiplexingManager(java.lang.String host, int port) throws java.net.UnknownHostException, java.io.IOException
protected MultiplexingManager(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
Method Detail |
protected void setup() throws java.io.IOException
java.io.IOException
public static MultiplexingManager getaManager(int port) throws java.io.IOException
port
-
java.io.IOException
public static MultiplexingManager getaManager(java.net.Socket socket) throws java.io.IOException
socket
-
java.io.IOException
- TODO: what if multiplexor already exists?public static MultiplexingManager getaManagerByLocalAddress(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
public static MultiplexingManager getaManagerByRemoteAddress(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
public static boolean isOnClient()
public static void setOnClient(boolean isOnClient)
public void incrementReferences()
public void releaseReference()
public int getReferenceCount()
public void bind(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
protected void registerByLocalAddress(java.net.InetSocketAddress address)
protected void registerByRemoteAddress(java.net.InetSocketAddress address)
address
- public void connect(java.net.InetSocketAddress address) throws java.io.IOException
address
-
java.io.IOException
public void registerServerSocket(java.net.ServerSocket serverSocket) throws java.io.IOException
java.io.IOException
public void unRegisterServerSocket(java.net.ServerSocket serverSocket) throws java.io.IOException
serverSocket
-
java.io.IOException
public MultiplexingManager.StreamPair registerSocket(VirtualSocket socket) throws java.io.IOException
socket
-
java.io.IOException
public void unRegisterSocket(VirtualSocket socket) throws java.io.IOException
socket
-
java.io.IOException
public void registerRemoteServerSocket()
public void unRegisterRemoteServerSocket()
public MultiplexingInputStream getAnInputStream(SocketId socketId, VirtualSocket socket) throws java.io.IOException
socketId
- socket
- TODO
java.io.IOException
public boolean isConnectedRemoteSocket(SocketId socketId)
socketId
-
public boolean isServerSocketRegistered()
public java.net.ServerSocket getServerSocket()
public java.io.OutputStream getOutputStreamByLocalSocket(SocketId socketId)
socketId
-
public java.util.Collection getAllOutputStreams()
public VirtualSocket getSocketByLocalPort(SocketId socketId)
socketId
-
public OutputMultiplexor getOutputMultiplexor()
public Protocol getProtocol()
public java.net.Socket getSocket()
public boolean isBound()
public boolean isConnected()
public void shutdown()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |