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 da...@apache.org on 2007/02/15 17:05:05 UTC
svn commit: r507974 - in
/webservices/kandula/branches/Kandula_1/src/java/org/apache/kandula/coordinator:
CallbackRegistry.java CoordinationService.java
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: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org