public class ConnectorAdapter
extends java.lang.Thread
This adapter assumes a simple protocol where two bytes define a (short) object size with the object data to follow. Note: this limits the size of serialized objects to 32676 bytes... even though, for example, datagram packets can hold twice that. :P
| Modifier and Type | Class and Description | 
|---|---|
protected class  | 
ConnectorAdapter.WriterThread  | 
| Constructor and Description | 
|---|
ConnectorAdapter(Connector connector,
                MessageProtocol protocol,
                MessageListener<java.lang.Object> dispatcher,
                ErrorListener<java.lang.Object> errorHandler,
                boolean reliable)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
close()  | 
protected void | 
dispatch(Message m)  | 
protected void | 
handleError(java.lang.Exception e)  | 
void | 
run()  | 
void | 
write(java.nio.ByteBuffer data)  | 
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yieldpublic ConnectorAdapter(Connector connector, MessageProtocol protocol, MessageListener<java.lang.Object> dispatcher, ErrorListener<java.lang.Object> errorHandler, boolean reliable)
public void close()
protected void dispatch(Message m)
public void write(java.nio.ByteBuffer data)
protected void handleError(java.lang.Exception e)
public void run()
run in interface java.lang.Runnablerun in class java.lang.Thread