public interface IOFilterManager
Modifier and Type | Method and Description |
---|---|
void |
beginHandshake() |
byte[] |
handleBlockingContant(byte[] buffer,
int slowConsumerTimeout) |
byte[] |
handleNoneBlockingContant(Reader.Context ctx,
byte[] bytes) |
void |
writeBytesBlocking(ByteBuffer dataBuffer) |
void |
writeBytesNonBlocking(Writer.Context ctx) |
void writeBytesNonBlocking(Writer.Context ctx) throws IOException, IOFilterException
IOException
IOFilterException
byte[] handleNoneBlockingContant(Reader.Context ctx, byte[] bytes) throws IOException, IOFilterException
IOException
IOFilterException
byte[] handleBlockingContant(byte[] buffer, int slowConsumerTimeout) throws ClosedChannelException, IOException, IOFilterException
void writeBytesBlocking(ByteBuffer dataBuffer) throws ClosedChannelException, SlowConsumerException, IOException, IOFilterException
void beginHandshake() throws IOFilterException, IOException
IOFilterException
IOException
Copyright © GigaSpaces.