Examples of resetHeader()

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

145
146
147
148
149
150
151
152
153
154
155
   
    public Object beforePush(StreamOutputStream anOut, Msg aMsg)
        throws IOException {
        MsgHeader header = aMsg.getHeader();
        MsgBody.Type type  = (MsgBody.Type)
            header.resetHeader(MsgHeaderConstants.BODY_TYPE);
        if ( type == MsgBody.Type.REQUEST ) {
            anOut.writeByte(REQUEST);
        } else {
            anOut.writeByte(RESPONSE);
        }
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

152
153
154
155
156
157
158
159
160
161
162
            anOut.writeByte(REQUEST);
        } else {
            anOut.writeByte(RESPONSE);
        }
        RequestSender.RequestID reqID  = (RequestSender.RequestID)
            header.resetHeader(MsgHeaderConstants.CORRELATION_ID);
        anOut.writeByte(reqID.getID());
        Integer version = (Integer)
            header.getHeader(MsgHeaderConstants.TOPOLOGY_VERSION);
        NodeTopology topology = getTopology(version.intValue());
        // Uses only the current topology to compress the data.
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

166
167
168
169
170
171
172
173
174
175
176
        }
        anOut.writeByte(TOPOLOGY);
        anOut.writeInt(topology.getVersion());
       
        NodeInfo info =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.SRC_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        info =
           (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

170
171
172
173
174
175
176
177
178
179
180
        NodeInfo info =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.SRC_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        info =
           (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        NodeInfo target =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODES);
        anOut.writeInt(topology.getIDOfNode(target));
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

174
175
176
177
178
179
180
181
182
183
184
        info =
           (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        NodeInfo target =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODES);
        anOut.writeInt(topology.getIDOfNode(target));
        return null;
    }
   
    public void afterPush(StreamOutputStream anOut, Msg aMsg,
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

145
146
147
148
149
150
151
152
153
154
155
   
    public Object beforePush(StreamOutputStream anOut, Msg aMsg)
        throws IOException {
        MsgHeader header = aMsg.getHeader();
        MsgBody.Type type  = (MsgBody.Type)
            header.resetHeader(MsgHeaderConstants.BODY_TYPE);
        if ( type == MsgBody.Type.REQUEST ) {
            anOut.writeByte(REQUEST);
        } else {
            anOut.writeByte(RESPONSE);
        }
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

152
153
154
155
156
157
158
159
160
161
162
            anOut.writeByte(REQUEST);
        } else {
            anOut.writeByte(RESPONSE);
        }
        RequestSender.RequestID reqID  = (RequestSender.RequestID)
            header.resetHeader(MsgHeaderConstants.CORRELATION_ID);
        anOut.writeByte(reqID.getID());
        Integer version = (Integer)
            header.getHeader(MsgHeaderConstants.TOPOLOGY_VERSION);
        NodeTopology topology = getTopology(version.intValue());
        // Uses only the current topology to compress the data.
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

166
167
168
169
170
171
172
173
174
175
176
        }
        anOut.writeByte(TOPOLOGY);
        anOut.writeInt(topology.getVersion());
       
        NodeInfo info =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.SRC_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        info =
           (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

170
171
172
173
174
175
176
177
178
179
180
        NodeInfo info =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.SRC_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        info =
           (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        NodeInfo target =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODES);
        anOut.writeInt(topology.getIDOfNode(target));
View Full Code Here

Examples of org.apache.geronimo.messaging.MsgHeader.resetHeader()

174
175
176
177
178
179
180
181
182
183
184
        info =
           (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODE);
        anOut.writeInt(topology.getIDOfNode(info));
       
        NodeInfo target =
            (NodeInfo) header.resetHeader(MsgHeaderConstants.DEST_NODES);
        anOut.writeInt(topology.getIDOfNode(target));
        return null;
    }
   
    public void afterPush(StreamOutputStream anOut, Msg aMsg,
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.