public class GzipInterceptor extends ChannelInterceptorBase implements GzipInterceptorMBean
ChannelInterceptor.InterceptorEvent
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BUFFER_SIZE |
static int |
DEFAULT_OPTION_COMPRESSION_ENABLE |
protected static StringManager |
sm |
optionFlag
Constructor and Description |
---|
GzipInterceptor() |
Modifier and Type | Method and Description |
---|---|
static byte[] |
compress(byte[] data) |
static byte[] |
decompress(byte[] data) |
long |
getCompressedSizeRX() |
long |
getCompressedSizeTX() |
int |
getCompressionMinSize() |
int |
getCount() |
int |
getCountCompressedRX() |
int |
getCountCompressedTX() |
int |
getCountUncompressedRX() |
int |
getCountUncompressedTX() |
int |
getInterval() |
long |
getSizeRX() |
long |
getSizeTX() |
boolean |
getStatsEnabled() |
long |
getUncompressedSizeRX() |
long |
getUncompressedSizeTX() |
void |
messageReceived(ChannelMessage msg)
the
messageReceived is invoked when a message is received. |
void |
report() |
void |
reset() |
void |
sendMessage(Member[] destination,
ChannelMessage msg,
InterceptorPayload payload)
The
sendMessage method is called when a message is being sent to one more destinations. |
void |
setCompressionMinSize(int compressionMinSize)
Set the minimum payload size for compression to be enabled.
|
void |
setInterval(int interval)
If statistics collection is enabled, set the number of messages between
statistics reports being written to the log.
|
void |
setStatsEnabled(boolean statsEnabled)
Configure whether the interceptor collects statistics.
|
fireInterceptorEvent, getChannel, getLocalMember, getMember, getMembers, getNext, getOptionFlag, getPrevious, hasMembers, heartbeat, memberAdded, memberDisappeared, okToProcess, setChannel, setNext, setOptionFlag, setPrevious, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getOptionFlag, setOptionFlag
protected static final StringManager sm
public static final int DEFAULT_BUFFER_SIZE
public static final int DEFAULT_OPTION_COMPRESSION_ENABLE
public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException
ChannelInterceptor
sendMessage
method is called when a message is being sent to one more destinations.
The interceptor can modify any of the parameters and then pass on the message down the stack by
invoking getNext().sendMessage(destination,msg,payload)
getNext().sendMessage(destination,msg,payload)
sendMessage
in interface ChannelInterceptor
sendMessage
in class ChannelInterceptorBase
destination
- Member[] - the destination for this messagemsg
- ChannelMessage - the message to be sentpayload
- InterceptorPayload - the payload, carrying an error handler and future useful data, can be nullChannelException
- if a serialization error happens.ErrorHandler
,
InterceptorPayload
public void messageReceived(ChannelMessage msg)
ChannelInterceptor
messageReceived
is invoked when a message is received.
ChannelMessage.getAddress()
is the sender, or the reply-to address
if it has been overwritten.messageReceived
in interface ChannelInterceptor
messageReceived
in class ChannelInterceptorBase
msg
- ChannelMessagepublic static byte[] compress(byte[] data) throws IOException
IOException
public static byte[] decompress(byte[] data) throws IOException
data
- Data to decompressIOException
- Compression errorpublic void report()
report
in interface GzipInterceptorMBean
public int getCompressionMinSize()
getCompressionMinSize
in interface GzipInterceptorMBean
public void setCompressionMinSize(int compressionMinSize)
GzipInterceptorMBean
setCompressionMinSize
in interface GzipInterceptorMBean
compressionMinSize
- The new minimum payload sizepublic boolean getStatsEnabled()
getStatsEnabled
in interface GzipInterceptorMBean
true
if the interceptor is configured to collect
statistics, otherwise false
public void setStatsEnabled(boolean statsEnabled)
GzipInterceptorMBean
setStatsEnabled
in interface GzipInterceptorMBean
statsEnabled
- true
to enable statistics collections,
otherwise false
public int getInterval()
getInterval
in interface GzipInterceptorMBean
public void setInterval(int interval)
GzipInterceptorMBean
setInterval
in interface GzipInterceptorMBean
interval
- The new interval between reportspublic int getCount()
getCount
in interface GzipInterceptorMBean
public int getCountCompressedTX()
getCountCompressedTX
in interface GzipInterceptorMBean
public int getCountUncompressedTX()
getCountUncompressedTX
in interface GzipInterceptorMBean
public int getCountCompressedRX()
getCountCompressedRX
in interface GzipInterceptorMBean
public int getCountUncompressedRX()
getCountUncompressedRX
in interface GzipInterceptorMBean
public long getSizeTX()
getSizeTX
in interface GzipInterceptorMBean
public long getCompressedSizeTX()
getCompressedSizeTX
in interface GzipInterceptorMBean
public long getUncompressedSizeTX()
getUncompressedSizeTX
in interface GzipInterceptorMBean
public long getSizeRX()
getSizeRX
in interface GzipInterceptorMBean
public long getCompressedSizeRX()
getCompressedSizeRX
in interface GzipInterceptorMBean
public long getUncompressedSizeRX()
getUncompressedSizeRX
in interface GzipInterceptorMBean
public void reset()
reset
in interface GzipInterceptorMBean
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.