You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ja...@apache.org on 2004/10/06 15:06:55 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server RMInvoker.java
jaliya 2004/10/06 06:06:55
Modified: sandesha/src/org/apache/sandesha/server RMInvoker.java
Log:
when inserting messages to the queues the UUID should be appended with "uuid:"
this is only required inside sandesha code
Revision Changes Path
1.2 +12 -4 ws-fx/sandesha/src/org/apache/sandesha/server/RMInvoker.java
Index: RMInvoker.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/RMInvoker.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- RMInvoker.java 30 Sep 2004 10:53:15 -0000 1.1
+++ RMInvoker.java 6 Oct 2004 13:06:55 -0000 1.2
@@ -104,6 +104,7 @@
boolean firstMsgOfResponseSeq = !storageManager
.isResponseSequenceExist(rmMessageContext
.getSequenceID());
+
storageManager.insertResponseMessage(rmMessageContext); //This
// will
// automatically
@@ -144,11 +145,14 @@
.setMessageType(Constants.MSG_TYPE_CREATE_SEQUENCE_REQUEST);
UUIDGen uuid = UUIDGenFactory.getUUIDGen();
- //String id = uuid.nextUUID();
- String id = "abcdefghijk";
-
+ String id = uuid.nextUUID();
+ //String id = "abcdefghijk";
+
+ //Need to add "uuid" or we can always remove this part
+ //Posible Problem
+ //TODO
storageManager.setTemporaryOutSequence(rmMsgContext
- .getSequenceID(), id);
+ .getSequenceID(), "uuid:"+id);
SOAPEnvelope createSequenceEnvelope = EnvelopeCreator
.createCreateSequenceEnvelope(id,
rmMsgContext, Constants.SERVER);
@@ -164,6 +168,8 @@
.getAddress().toString());
System.out.println("ddddd");
+
+ rmMsgContext.setMessageID("uuid:"+id);
storageManager
.addCreateSequenceRequest(rmMsgContext);
System.out.println("END OF IF");
@@ -172,6 +178,8 @@
ServerQueue sq = ServerQueue.getInstance();
sq.displayPriorityQueue();
+ sq.displayOutgoingMap();
+ sq.displayIncomingMap();
//we need to check whether we have this sequence in the
// response queue.