|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.catalina.cluster.io.SocketObjectReader
The object reader object is an object used in conjunction with
java.nio TCP messages. This object stores the message bytes in a
XByteBuffer
until a full package has been received.
When a full package has been received, the append method will call messageDataReceived
on the callback object associated with this object reader.
This object uses an XByteBuffer which is an extendable object buffer that also allows
for message encoding and decoding.
Constructor Summary | |
SocketObjectReader(java.net.Socket socket,
ListenCallback callback)
use this socket and callback to receive messages |
Method Summary | |
int |
append(byte[] data,
int off,
int len)
Append new bytes to buffer. |
int |
execute()
send message to callback |
int |
write(byte[] data)
write data to socket (ack) |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SocketObjectReader(java.net.Socket socket, ListenCallback callback)
socket
- listener socketcallback
- ClusterReceiverBase listenerMethod Detail |
public int append(byte[] data, int off, int len) throws java.io.IOException
data
- new transfer bufferoff
- offsetlen
- length in buffer
java.io.IOException
ClusterReceiverBase.messageDataReceived(ClusterData)
,
XByteBuffer.doesPackageExist()
,
XByteBuffer.extractPackage(boolean)
public int execute() throws java.io.IOException
java.io.IOException
append(byte[], int, int)
public int write(byte[] data) throws java.io.IOException
data
-
java.io.IOException
ClusterReceiverBase.sendAck()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |