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() . |
java.lang.Object |
down(Event evt)
We compress the payload if it is larger than
min_size . |
java.lang.String |
getName() |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
boolean |
setProperties(java.util.Properties props)
Configures the protocol initially.
|
java.lang.Object |
up(Event evt)
If there is no header, we pass the message up.
|
downThreadEnabled, dumpStats, enableStats, getDownProtocol, getProperties, getProtocolStack, getThreadFactory, getTransport, getUpProtocol, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setPropertiesInternal, setProtocolStack, setUpProtocol, start, statsEnabled, stop, upThreadEnabled
public void init() throws java.lang.Exception
Protocol
public void destroy()
Protocol
Channel.close()
.
Does some cleanup; after the call the VM will terminatepublic boolean setProperties(java.util.Properties props)
Protocol
"loopback=false;unicast_inport=4444"
setProperties
in class Protocol
public java.lang.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 ? 1998-2008 Bela Ban. All Rights Reserved.