svn commit: r365403 - in /webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility: Callback.java CallbackRegistry.java TransactionImpl.java TransactionManagerImpl.java TxHandler.java

[dasarath]

Author: dasarath
Date: Mon Jan  2 11:19:20 2006
New Revision: 365403

URL: http://svn.apache.org/viewcvs?rev=365403&view=rev
Log: (empty)

Removed:
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/TransactionImpl.java
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/TransactionManagerImpl.java
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/TxHandler.java
Modified:
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/Callback.java
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/CallbackRegistry.java

Modified: 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/Callback.java
URL: 
http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/Callback.java?rev=365403&r1=365402&r2=365403&view=diff
==============================================================================
--- 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/Callback.java
 (original)
+++ 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/Callback.java
 Mon Jan  2 11:19:20 2006
@@ -4,12 +4,14 @@
  */
 package org.apache.ws.transaction.utility;
 
+import org.apache.ws.transaction.coordinator.TimedOutException;
+
 /**
  * @author Dasarath Weeratunge
  *  
  */
 public interface Callback {
 
-       void timeout();
+       void timeout() throws TimedOutException;
 
 }

Modified: 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/CallbackRegistry.java
URL: 
http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/CallbackRegistry.java?rev=365403&r1=365402&r2=365403&view=diff
==============================================================================
--- 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/CallbackRegistry.java
 (original)
+++ 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/utility/CallbackRegistry.java
 Mon Jan  2 11:19:20 2006
@@ -17,12 +17,14 @@
 import org.apache.axis.MessageContext;
 import org.apache.axis.message.addressing.AddressingHeaders;
 import org.apache.axis.message.addressing.Constants;
+import org.apache.ws.transaction.coordinator.TimedOutException;
 
 /**
  * @author Dasarath Weeratunge
  *  
  */
 public class CallbackRegistry {
+       
        public static final QName CALLBACK_REF = new QName(
                        "http://ws.apache.org/kandula";, "CallbackRef");
 
@@ -34,7 +36,7 @@
        // for testing
        // only...
 
-       private Timer timer = new Timer();
+       private static Timer timer = new Timer();
 
        private static final CallbackRegistry instance = new CallbackRegistry();
 
@@ -61,7 +63,12 @@
                timer.schedule(new TimerTask() {
                        public void run() {
                                callbacks.remove(callback);
-                               callback.timeout();
+                               try {
+                                       callback.timeout();
+                               }
+                               catch (TimedOutException e){
+                                       e.printStackTrace();
+                               }
                        }
                }, timeout);
        }



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