svn commit: r578687 - /webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java

[sumedha]

Author: sumedha
Date: Mon Sep 24 00:35:03 2007
New Revision: 578687

URL: http://svn.apache.org/viewvc?rev=578687&view=rev
Log:
Transaction should be committed, only if AxisEngine.send() is successful

Modified:
    
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java

Modified: 
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java?rev=578687&r1=578686&r2=578687&view=diff
==============================================================================
--- 
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java
 (original)
+++ 
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java
 Mon Sep 24 00:35:03 2007
@@ -258,9 +258,6 @@
        
                        SandeshaUtil.startWorkersForSequence(context, rmdBean);
 
-                       //
-                       // We have done all of our updates, so commit the 
transaction
-                       if(transaction != null && transaction.isActive()) 
transaction.commit();
                        
                        try{
                                AxisEngine.send(outMessage);                    
        
@@ -274,7 +271,12 @@
                                        log.debug("Exit: 
CreateSeqMsgProcessor::processInMessage " + Boolean.FALSE);                     
       
                                return false;
                        }
-       
+
+                       // We have done all of our updates, so commit the 
transaction
+                       if(transaction != null && transaction.isActive()) {
+                               transaction.commit();
+                       }
+                       
                        EndpointReference replyTo = createSeqMsg.getReplyTo();
                        if(replyTo == null || replyTo.hasAnonymousAddress()) {
                                TransportUtils.setResponseWritten(createSeqMsg, 
true);



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]