public class COMPRESS extends Protocol
Modifier and Type | Class and Description |
---|---|
static class |
COMPRESS.CompressHeader |
Constructor and Description |
---|
COMPRESS() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
This method is called on a
Channel.close() . |
Object |
down(Event evt)
We compress the payload if it is larger than
min_size . |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
Object |
up(Event evt)
If there is no header, we pass the message up.
|
dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getId, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getValue, isErgonomics, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, start, statsEnabled, stop
public void init() throws Exception
Protocol
public void destroy()
Protocol
Channel.close()
.
Does some cleanup; after the call the VM will terminatepublic Object down(Event evt)
min_size
. In this case we add a header containing
the original size before compression. Otherwise we add no header.Copyright © 2012 JBoss by Red Hat. All Rights Reserved.