You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by me...@apache.org on 2007/03/18 01:00:10 UTC
svn commit: r519477 - in
/incubator/tuscany/java/sca/contrib/discovery/jxta/src:
main/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryService.java
test/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryServiceTestCase.java
Author: meerajk
Date: Sat Mar 17 17:00:09 2007
New Revision: 519477
URL: http://svn.apache.org/viewvc?view=rev&rev=519477
Log:
Added async error reporting.
Modified:
incubator/tuscany/java/sca/contrib/discovery/jxta/src/main/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryService.java
incubator/tuscany/java/sca/contrib/discovery/jxta/src/test/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryServiceTestCase.java
Modified: incubator/tuscany/java/sca/contrib/discovery/jxta/src/main/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryService.java
URL: http://svn.apache.org/viewvc/incubator/tuscany/java/sca/contrib/discovery/jxta/src/main/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryService.java?view=diff&rev=519477&r1=519476&r2=519477
==============================================================================
--- incubator/tuscany/java/sca/contrib/discovery/jxta/src/main/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryService.java (original)
+++ incubator/tuscany/java/sca/contrib/discovery/jxta/src/main/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryService.java Sat Mar 17 17:00:09 2007
@@ -47,6 +47,8 @@
import org.apache.tuscany.service.discovery.jxta.prp.TuscanyQueryHandler;
import org.apache.tuscany.spi.services.discovery.AbstractDiscoveryService;
import org.apache.tuscany.spi.services.discovery.DiscoveryException;
+import org.apache.tuscany.spi.services.work.NotificationListener;
+import org.apache.tuscany.spi.services.work.NotificationListenerAdaptor;
import org.apache.tuscany.spi.services.work.WorkScheduler;
import org.apache.tuscany.spi.util.stax.StaxUtil;
import org.omg.CORBA.Any;
@@ -121,15 +123,21 @@
*/
@Override
public void onStart() throws DiscoveryException {
- workScheduler.scheduleWork(new Runnable() {
+
+ Runnable runnable = new Runnable() {
public void run() {
try {
startService();
} catch(DiscoveryException ex) {
+ ex.printStackTrace();
throw new JxtaException(ex);
}
}
- });
+ };
+
+ NotificationListener<Runnable> listener = new NotificationListenerAdaptor<Runnable>();
+ workScheduler.scheduleWork(runnable, listener);
+
}
/**
Modified: incubator/tuscany/java/sca/contrib/discovery/jxta/src/test/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryServiceTestCase.java
URL: http://svn.apache.org/viewvc/incubator/tuscany/java/sca/contrib/discovery/jxta/src/test/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryServiceTestCase.java?view=diff&rev=519477&r1=519476&r2=519477
==============================================================================
--- incubator/tuscany/java/sca/contrib/discovery/jxta/src/test/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryServiceTestCase.java (original)
+++ incubator/tuscany/java/sca/contrib/discovery/jxta/src/test/java/org/apache/tuscany/service/discovery/jxta/JxtaDiscoveryServiceTestCase.java Sat Mar 17 17:00:09 2007
@@ -120,8 +120,16 @@
discoveryService.setConfigurator(configurator);
discoveryService.setWorkScheduler(new WorkScheduler() {
- public <T extends Runnable> void scheduleWork(T work, NotificationListener<T> listener) {
- scheduleWork(work, null);
+ public <T extends Runnable> void scheduleWork(final T work, final NotificationListener<T> listener) {
+ new Thread() {
+ public void run() {
+ try {
+ work.run();
+ } catch(Exception ex) {
+ listener.workFailed(work, ex);
+ }
+ }
+ }.start();
}
public <T extends Runnable> void scheduleWork(final T work) {
new Thread() {
---------------------------------------------------------------------
To unsubscribe, e-mail: tuscany-commits-unsubscribe@ws.apache.org
For additional commands, e-mail: tuscany-commits-help@ws.apache.org