public class GzipInterceptor extends ChannelInterceptorBase
ChannelInterceptor.InterceptorEvent
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BUFFER_SIZE |
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) |
void |
messageReceived(ChannelMessage msg)
the
messageReceived is invoked when a message is received. |
void |
sendMessage(Member[] destination,
ChannelMessage msg,
InterceptorPayload payload)
The
sendMessage method is called when a message is being sent to one more destinations. |
fireInterceptorEvent, getChannel, getLocalMember, getMember, getMembers, getNext, getOptionFlag, getPrevious, hasMembers, heartbeat, memberAdded, memberDisappeared, okToProcess, setChannel, setNext, setOptionFlag, setPrevious, start, stop
protected static final StringManager sm
public static final int DEFAULT_BUFFER_SIZE
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
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 java.io.IOException
java.io.IOException
public static byte[] decompress(byte[] data) throws java.io.IOException
data
- Data to decompressjava.io.IOException
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.