public abstract class CompressExtension extends AbstractExtension
AbstractLifeCycle.AbstractLifeCycleListener
Container.InheritedListener, Container.Listener
LifeCycle.Listener
Modifier and Type | Field and Description |
---|---|
protected static byte[] |
TAIL_BYTES |
Modifier | Constructor and Description |
---|---|
protected |
CompressExtension() |
Modifier and Type | Method and Description |
---|---|
protected ByteAccumulator |
decompress(byte[] input) |
protected void |
forwardIncoming(Frame frame,
ByteAccumulator accumulator) |
Deflater |
getDeflater() |
Inflater |
getInflater() |
boolean |
isRsv1User()
Indicates use of RSV1 flag for indicating deflation is in use.
|
protected void |
notifyCallbackFailure(WriteCallback callback,
Throwable failure) |
protected void |
notifyCallbackSuccess(WriteCallback callback) |
void |
outgoingFrame(Frame frame,
WriteCallback callback,
BatchMode batchMode)
A frame, and optional callback, intended for the network layer.
|
String |
toString() |
dump, dumpWithHeading, getBufferPool, getConfig, getConnection, getName, getNextIncoming, getNextOutgoing, getPolicy, incomingError, isRsv2User, isRsv3User, nextIncomingError, nextIncomingFrame, nextOutgoingFrame, setBufferPool, setConfig, setConnection, setNextIncomingFrames, setNextOutgoingFrames, setPolicy
addBean, addBean, addBean, addEventListener, contains, destroy, doStart, doStop, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBeans
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
incomingFrame
public Deflater getDeflater()
public Inflater getInflater()
public boolean isRsv1User()
isRsv1User
in interface Extension
isRsv1User
in class AbstractExtension
protected void forwardIncoming(Frame frame, ByteAccumulator accumulator)
protected ByteAccumulator decompress(byte[] input)
public void outgoingFrame(Frame frame, WriteCallback callback, BatchMode batchMode)
OutgoingFrames
frame
- the frame to eventually write to the network layer.callback
- the callback to notify when the frame is written.batchMode
- the batch mode requested by the sender.protected void notifyCallbackSuccess(WriteCallback callback)
protected void notifyCallbackFailure(WriteCallback callback, Throwable failure)
public String toString()
toString
in class AbstractExtension
Copyright © 1995-2014 Mort Bay Consulting. All Rights Reserved.