svn commit: r480983 - /incubator/ode/trunk/bpel-test/src/test/java/org/apache/ode/test/BPELTest.java

[mr...@apache.org]

Author: mriou
Date: Thu Nov 30 08:04:50 2006
New Revision: 480983

URL: http://svn.apache.org/viewvc?view=rev&rev=480983
Log:
Registering a listener on the store to notify the server of new deployments.

Modified:
    incubator/ode/trunk/bpel-test/src/test/java/org/apache/ode/test/BPELTest.java

Modified: incubator/ode/trunk/bpel-test/src/test/java/org/apache/ode/test/BPELTest.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-test/src/test/java/org/apache/ode/test/BPELTest.java?view=diff&rev=480983&r1=480982&r2=480983
==============================================================================
--- incubator/ode/trunk/bpel-test/src/test/java/org/apache/ode/test/BPELTest.java (original)
+++ incubator/ode/trunk/bpel-test/src/test/java/org/apache/ode/test/BPELTest.java Thu Nov 30 08:04:50 2006
@@ -20,10 +20,7 @@
 
 import junit.framework.TestCase;
 import org.apache.ode.bpel.engine.BpelServerImpl;
-import org.apache.ode.bpel.iapi.BpelEngineException;
-import org.apache.ode.bpel.iapi.Message;
-import org.apache.ode.bpel.iapi.MyRoleMessageExchange;
-import org.apache.ode.bpel.iapi.ProcessStore;
+import org.apache.ode.bpel.iapi.*;
 import org.apache.ode.bpel.memdao.BpelDAOConnectionFactoryImpl;
 import org.apache.ode.store.ProcessStoreImpl;
 import org.apache.ode.test.scheduler.TestScheduler;
@@ -52,6 +49,13 @@
 		server.setBindingContext(new BindingContextImpl());
 		server.setMessageExchangeContext(mexContext);
         store = new ProcessStoreImpl();
+        store.registerListener(new ProcessStoreListener() {
+            public void onProcessStoreEvent(ProcessStoreEvent event) {
+                // bounce the process
+                server.unregister(event.pid);
+                server.register(store.getProcessConfiguration(event.pid));
+            }
+        });
         server.init();
 		server.start();
 	}