svn commit: r507974 - in /webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator: CallbackRegistry.java CoordinationService.java

[dasarath]

Author: dasarath
Date: Thu Feb 15 08:05:04 2007
New Revision: 507974

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

Modified:
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CallbackRegistry.java
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CoordinationService.java

Modified: 
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CallbackRegistry.java
URL: 
http://svn.apache.org/viewvc/webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CallbackRegistry.java?view=diff&rev=507974&r1=507973&r2=507974
==============================================================================
--- 
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CallbackRegistry.java
 (original)
+++ 
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CallbackRegistry.java
 Thu Feb 15 08:05:04 2007
@@ -26,7 +26,7 @@
                        "http://ws.apache.org/kandula";, "CallbackRef");
 
        // FIXME:
-       public static final int DEFAULT_TIMEOUT_MILLIS = 180 * 1000;
+       public static final int DEFAULT_TIMEOUT_MILLIS = 20 * 1000;
 
        private static Timer timer = new Timer();
 
@@ -53,7 +53,7 @@
                        timeout = DEFAULT_TIMEOUT_MILLIS;
 
                System.out.println("[CallbackRegistry] registerCallback: 
timeout= "
-                               + timeout);
+                               + timeout + " callbacks.size= " + 
callbacks.size());
 
                timer.schedule(new TimerTask() {
                        public void run() {
@@ -61,7 +61,7 @@
                                try {
                                        callback.timeout();
                                } catch (TimedOutException e) {
-                                       e.printStackTrace();
+                                       //      e.printStackTrace();
                                }
                        }
                }, timeout);

Modified: 
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CoordinationService.java
URL: 
http://svn.apache.org/viewvc/webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CoordinationService.java?view=diff&rev=507974&r1=507973&r2=507974
==============================================================================
--- 
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CoordinationService.java
 (original)
+++ 
webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator/CoordinationService.java
 Thu Feb 15 08:05:04 2007
@@ -36,7 +36,7 @@
        private CoordinationService() {
        }
 
-       private CoordinationContext createCoordinationContext(
+       public CoordinationContext createCoordinationContext(
                        String coordinationType, long timeout)
                        throws UnsupportedCoordinationTypeException, 
MalformedURIException {
                if 
(!ATCoordinator.COORDINATION_TYPE_ID.equals(coordinationType))
@@ -116,7 +116,7 @@
                long timeout = 0;
                if (ex != null)
                        timeout = ex.get_value().longValue() * 1000;
-               CoordinationContext ctx;
+               CoordinationContext ctx = null;
                try {
                        ctx = createCoordinationContext(t, timeout);
                } catch (MalformedURIException e) {



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