chamikara 2005/01/10 14:59:32
Modified: sandesha/src/org/apache/sandesha/client RMSender.java
Log:
method getTerminateSeqMessage was added
Revision Changes Path
1.16 +27 -15
ws-fx/sandesha/src/org/apache/sandesha/client/RMSender.java
Index: RMSender.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/client/RMSender.java,v
retrieving revision 1.15
retrieving revision 1.16
diff -u -r1.15 -r1.16
--- RMSender.java 24 Dec 2004 04:44:23 -0000 1.15
+++ RMSender.java 10 Jan 2005 22:59:31 -0000 1.16
@@ -118,20 +118,21 @@
}
if(requestMesssageContext.isLastMessage()){
-
while(!storageManager.isAckComplete(requestMesssageContext.getSequenceID())){
-
Thread.sleep(Constants.CLIENT_RESPONSE_CHECKING_INTERVAL);
- }
- if(requestMesssageContext.getSync()){
-
while(!storageManager.isResponseComplete(requestMesssageContext.getSequenceID())){
-
Thread.sleep(Constants.CLIENT_RESPONSE_CHECKING_INTERVAL);
- }
- }
-
storageManager.insertTerminateSeqMessage(getTerminateSeqMessage());
+//
while(!storageManager.isAckComplete(requestMesssageContext.getSequenceID())){
+//
Thread.sleep(Constants.CLIENT_RESPONSE_CHECKING_INTERVAL);
+// }
+// if(requestMesssageContext.getSync()){
+//
while(!storageManager.isResponseComplete(requestMesssageContext.getSequenceID())){
+//
Thread.sleep(Constants.CLIENT_RESPONSE_CHECKING_INTERVAL);
+// }
+// }
+
storageManager.insertTerminateSeqMessage(getTerminateSeqMessage(requestMesssageContext));
- if(storageManager.isAllSequenceComplete()){
- senderThread.stop();
- sas.stop();
- }
+
+// if(storageManager.isAllSequenceComplete()){
+// senderThread.stop();
+// sas.stop();
+// }
}
@@ -145,9 +146,20 @@
/**
* @return
*/
- private RMMessageContext getTerminateSeqMessage() {
+ private RMMessageContext getTerminateSeqMessage(RMMessageContext
rmMessageContext) {
+ RMMessageContext terSeqRMMsgContext = new RMMessageContext();
+ MessageContext terSeqMsgContext = new
MessageContext(rmMessageContext.getMsgContext().getAxisEngine());
+ //RMMessageContext.copyMessageContext(msgContext, messageContext);
+
terSeqRMMsgContext.setOutGoingAddress(rmMessageContext.getOutGoingAddress());
+ SOAPEnvelope
terSeqEnv=EnvelopeCreator.createTerminatSeqMessage(rmMessageContext);
+ Message terSeqMsg= new Message(terSeqEnv);
+
+ terSeqMsgContext.setRequestMessage(terSeqMsg);
+ terSeqRMMsgContext.setMsgContext(terSeqMsgContext);
+
+
terSeqRMMsgContext.setMessageType(Constants.MSG_TYPE_TERMINATE_SEQUENCE);
// TODO Auto-generated method stub
- return null;
+ return terSeqRMMsgContext;
}
/**
