com.gigaspaces.lrmi.nio.filters

Class IOStreamFilterManager

java.lang.Object

com.gigaspaces.lrmi.nio.filters.IOStreamFilterManager

All Implemented Interfaces:

IOFilterManager

public class IOStreamFilterManager
extends Object
implements IOFilterManager

Constructor Summary

Constructors

Constructor and Description
IOStreamFilterManager(Reader reader, Writer writer, IOStreamFilter filter)

Method Summary

Modifier and Type	Method and Description
void	beginHandshake()
byte[]	handleBlockingContant(byte[] bytes, int slowConsumerTimeout)
byte[]	handleNoneBlockingContant(Reader.Context ctx, byte[] bytes)
void	setUseClientMode(boolean mode)
void	writeBytesBlocking(ByteBuffer dataBuffer)
void	writeBytesNonBlocking(Writer.Context ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IOStreamFilterManager

public IOStreamFilterManager(Reader reader,
                             Writer writer,
                             IOStreamFilter filter)

Method Detail

handleBlockingContant

public byte[] handleBlockingContant(byte[] bytes,
                                    int slowConsumerTimeout)
                             throws IOException,
                                    IOFilterException

Specified by:

handleBlockingContant in interface IOFilterManager

Throws:

IOException

IOFilterException

handleNoneBlockingContant

public byte[] handleNoneBlockingContant(Reader.Context ctx,
                                        byte[] bytes)
                                 throws IOException,
                                        IOFilterException

Specified by:

handleNoneBlockingContant in interface IOFilterManager

Throws:

IOException

IOFilterException

writeBytesBlocking

public void writeBytesBlocking(ByteBuffer dataBuffer)
                        throws IOException,
                               IOFilterException

Specified by:

writeBytesBlocking in interface IOFilterManager

Throws:

IOException

IOFilterException

writeBytesNonBlocking

public void writeBytesNonBlocking(Writer.Context ctx)
                           throws IOException

Specified by:

writeBytesNonBlocking in interface IOFilterManager

Throws:

IOException

beginHandshake

public void beginHandshake()

Specified by:

beginHandshake in interface IOFilterManager

setUseClientMode

public void setUseClientMode(boolean mode)