com.gigaspaces.lrmi.nio.filters
Class IOStreamCompressionFilter

java.lang.Object
  com.gigaspaces.lrmi.nio.filters.IOStreamCompressionFilter

All Implemented Interfaces:

IOFilter, IOStreamFilter

public class IOStreamCompressionFilter
extends Object
implements IOStreamFilter

Use this network filter to send compress messages between client and server.

Author:

barak

Nested Class Summary

static class	IOStreamCompressionFilter.Algo
static class	IOStreamCompressionFilter.IOStreamCompressionFilterFactory

Constructor Summary

IOStreamCompressionFilter(IOStreamCompressionFilter.Algo algo)

Method Summary

void	setCompressionLevel(int compressionLevel)
void	setRemoteAddress(SocketAddress remoteAddress)
byte[]	unrwap(ByteBuffer buf)
byte[]	wrap(ByteBuffer buf)

Methods inherited from class java.lang.Object

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

Constructor Detail

IOStreamCompressionFilter

public IOStreamCompressionFilter(IOStreamCompressionFilter.Algo algo)

Method Detail

setCompressionLevel

public void setCompressionLevel(int compressionLevel)

Parameters:

compressionLevel - compresson level should be a number in (0-9)

unrwap

public byte[] unrwap(ByteBuffer buf)
              throws DataFormatException

Specified by:

unrwap in interface IOStreamFilter

Throws:

DataFormatException

wrap

public byte[] wrap(ByteBuffer buf)
            throws Exception

Specified by:

wrap in interface IOStreamFilter

Throws:

Exception

setRemoteAddress

public void setRemoteAddress(SocketAddress remoteAddress)

Specified by:

setRemoteAddress in interface IOFilter