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