|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.geronimo.messaging.remotenode.LogicalCompression
Logical compression of Msgs.
Its goal is to compress Msgs to be sent to other nodes. The compression is
based on a shared knowledge such as a Topology.
Constructor Summary | |
LogicalCompression()
|
Method Summary | |
void |
afterPop(StreamInputStream anIn,
Msg aMsg,
Object anOpaque)
Notifies the implementation that a Msg has been popped. |
void |
afterPush(StreamOutputStream anOut,
Msg aMsg,
Object anOpaque)
Notifies the implementation that a Msg has been pushed. |
Object |
beforePop(StreamInputStream anIn)
Notifies the implementation that a Msg is being popped. |
Object |
beforePush(StreamOutputStream anOut,
Msg aMsg)
Notifies the implementation that a Msg is being pushed. |
void |
commitTopology()
Commits the previousy prepared topology. |
void |
prepareTopology(NodeTopology aTopology)
Registers a future topology. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public LogicalCompression()
Method Detail |
public void prepareTopology(NodeTopology aTopology)
aTopology
- Topology.public void commitTopology()
public Object beforePop(StreamInputStream anIn) throws IOException
PopSynchronization
beforePop
in interface PopSynchronization
anIn
- Used to read information from the input stream before
the Msg itself.
IOException
- Indicates that an I/O error has occured.public void afterPop(StreamInputStream anIn, Msg aMsg, Object anOpaque) throws IOException
PopSynchronization
afterPop
in interface PopSynchronization
anIn
- Used to read information from the input stream after
the Msg itself.aMsg
- Msg which has just been popped.anOpaque
- Value returned by beforePop.
IOException
- Indicates that an I/O error has occured.public Object beforePush(StreamOutputStream anOut, Msg aMsg) throws IOException
PushSynchronization
beforePush
in interface PushSynchronization
anOut
- Used to write information before the Msg itself.aMsg
- Msg being pushed.
IOException
- Indicates that an I/O error has occured.public void afterPush(StreamOutputStream anOut, Msg aMsg, Object anOpaque) throws IOException
PushSynchronization
afterPush
in interface PushSynchronization
anOut
- Used to write information after the Msg itself.aMsg
- Msg which has just been pushed.anOpaque
- Value returned by beforePush.
IOException
- Indicates that an I/O error has occured.
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |