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();
}