public class XNioChannel extends Object
Constructor and Description |
---|
XNioChannel(SocketChannel socketChannel) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Object |
deserialize(ByteBuffer buffer) |
ReadProcessor |
getReadProcessor() |
SocketChannel |
getSocketChannel() |
ByteBuffer |
readBlocking() |
ByteBuffer |
readNonBlocking() |
void |
release() |
ByteBuffer |
serialize(Object obj) |
void |
setReadProcessor(ReadProcessor readProcessor) |
boolean |
tryAcquire() |
void |
writeBlocking(ByteBuffer buffer) |
public XNioChannel(SocketChannel socketChannel)
public boolean tryAcquire()
public void release()
public SocketChannel getSocketChannel()
public ByteBuffer serialize(Object obj) throws IOException
IOException
public Object deserialize(ByteBuffer buffer) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeBlocking(ByteBuffer buffer) throws IOException
IOException
public ByteBuffer readBlocking() throws IOException
IOException
public ByteBuffer readNonBlocking() throws IOException
IOException
public void close() throws IOException
IOException
public ReadProcessor getReadProcessor()
public void setReadProcessor(ReadProcessor readProcessor)
Copyright © GigaSpaces.