You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by gd...@apache.org on 2004/07/20 02:08:14 UTC
cvs commit: incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging MsgHeaderConstants.java MsgHeader.java Msg.java
gdamour 2004/07/19 17:08:14
Modified: sandbox/messaging/src/java/org/apache/geronimo/messaging
MsgHeaderConstants.java MsgHeader.java Msg.java
Log:
New MsgHeader defining the version number of the topology to be used when sending/routing Msgs.
Revision Changes Path
1.2 +8 -1 incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging/MsgHeaderConstants.java
Index: MsgHeaderConstants.java
===================================================================
RCS file: /home/cvs/incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging/MsgHeaderConstants.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- MsgHeaderConstants.java 11 May 2004 12:06:41 -0000 1.1
+++ MsgHeaderConstants.java 20 Jul 2004 00:08:13 -0000 1.2
@@ -81,4 +81,11 @@
*/
public static final Object BODY_TYPE = "BodyType";
+ /**
+ * Topology version in which the Msg is to be sent/received.
+ * <BR>
+ * It is used to send Msgs in a prepared (not yet committed) topology.
+ */
+ public static final Object TOPOLOGY_VERSION = "TopologyVersion";
+
}
1.2 +3 -2 incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging/MsgHeader.java
Index: MsgHeader.java
===================================================================
RCS file: /home/cvs/incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging/MsgHeader.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- MsgHeader.java 11 May 2004 12:06:41 -0000 1.1
+++ MsgHeader.java 20 Jul 2004 00:08:13 -0000 1.2
@@ -39,7 +39,8 @@
MsgHeaderConstants.DEST_NODE_PATH,
MsgHeaderConstants.DEST_NODES,
MsgHeaderConstants.SRC_ENDPOINT,
- MsgHeaderConstants.SRC_NODE};
+ MsgHeaderConstants.SRC_NODE,
+ MsgHeaderConstants.TOPOLOGY_VERSION};
/**
* Header maps.
1.3 +3 -1 incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging/Msg.java
Index: Msg.java
===================================================================
RCS file: /home/cvs/incubator-geronimo/sandbox/messaging/src/java/org/apache/geronimo/messaging/Msg.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- Msg.java 27 May 2004 14:29:44 -0000 1.2
+++ Msg.java 20 Jul 2004 00:08:14 -0000 1.3
@@ -81,6 +81,8 @@
header.getHeader(MsgHeaderConstants.DEST_NODES));
newHeader.addHeader(MsgHeaderConstants.BODY_TYPE,
MsgBody.Type.RESPONSE);
+ newHeader.addHeader(MsgHeaderConstants.TOPOLOGY_VERSION,
+ header.getHeader(MsgHeaderConstants.TOPOLOGY_VERSION));
return msg;
}