org.apache.catalina.tribes.io
public class ObjectReader extends Object
XByteBuffer until a full package has been received.
This object uses an XByteBuffer which is an extendable object buffer that also allows
for message encoding and decoding.
Version: $Revision: 467173 $, $Date: 2006-10-24 01:12:17 +0200 (Tue, 24 Oct 2006) $
| Field Summary | |
|---|---|
| protected boolean | accessed |
| protected long | lastAccess |
| protected static Log | log |
| Constructor Summary | |
|---|---|
| ObjectReader(SocketChannel channel)
Creates an ObjectReader for a TCP NIO socket channel | |
| ObjectReader(Socket socket)
Creates an ObjectReader for a TCP socket | |
| Method Summary | |
|---|---|
| void | access() |
| int | append(ByteBuffer data, int len, boolean count)
Append new bytes to buffer. |
| int | append(byte[] data, int off, int len, boolean count) |
| int | bufferSize() |
| void | close() |
| int | count()
Returns the number of packages that the reader has read |
| ChannelMessage[] | execute()
Send buffer to cluster listener (callback).
|
| void | finish() |
| long | getLastAccess() |
| boolean | hasPackage() |
| boolean | isAccessed() |
| boolean | isCancelled() |
| void | setCancelled(boolean cancelled) |
| void | setLastAccess(long lastAccess) |
ObjectReader for a TCP NIO socket channelParameters: channel - the channel to be read.
ObjectReader for a TCP socketParameters: socket Socket
Parameters: data new transfer buffer off offset len length in buffer
Returns: number of messages that sended to callback
Throws: java.io.IOException
See Also: countPackages
Returns: int
Returns: number of received packages/messages
Throws: java.io.IOException
See Also: org.apache.catalina.tribes.transport.ClusterReceiverBase#messageDataReceived(ChannelMessage) doesPackageExist