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/20 12:28:49 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server CreateSequenceProcessor.java CompositeProcessor.java
jaliya 2004/10/20 03:28:49
Modified: sandesha/src/org/apache/sandesha/server
CreateSequenceProcessor.java
CompositeProcessor.java
Log:
Only the formatting
Revision Changes Path
1.10 +1 -1 ws-fx/sandesha/src/org/apache/sandesha/server/CreateSequenceProcessor.java
Index: CreateSequenceProcessor.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/CreateSequenceProcessor.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- CreateSequenceProcessor.java 11 Oct 2004 10:57:58 -0000 1.9
+++ CreateSequenceProcessor.java 20 Oct 2004 10:28:49 -0000 1.10
@@ -61,7 +61,7 @@
String uuid = uuidGen.nextUUID();
//TODO
- storageManger.addSequence(uuid);
+ //storageManger.addSequence("uuid:"+uuid);
//Create the SOAPEnvelop to send and set it to the resEnv of
// rmMessageCotext.
1.8 +3 -3 ws-fx/sandesha/src/org/apache/sandesha/server/CompositeProcessor.java
Index: CompositeProcessor.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/CompositeProcessor.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -u -r1.7 -r1.8
--- CompositeProcessor.java 11 Oct 2004 10:57:58 -0000 1.7
+++ CompositeProcessor.java 20 Oct 2004 10:28:49 -0000 1.8
@@ -42,7 +42,6 @@
RMHeaders rmHeaders = rmMessageContext.getRMHeaders();
AcknowledgementProcessor ackProcessor = new AcknowledgementProcessor(
this.storageManger);
-
if (rmHeaders.getSequenceAcknowledgement() != null) {
ackProcessor.processMessage(rmMessageContext);
@@ -93,9 +92,10 @@
//TODO: Add to log.
}
- System.out.println("INSERT THE REQUEST MESSAGE.....\n");
+ System.out
+ .println("INFO: Inserting the request message ....\n");
//Insert the message to the INQUEUE
- storageManger.insertRequestMessage(rmMsgContext);
+ storageManger.insertIncomingMessage(rmMsgContext);
}
//Send an Ack for every message received by the server.