diff options
author | edwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68> | 2009-07-15 08:39:34 +0000 |
---|---|---|
committer | edwardsmj <edwardsmj@13f79535-47bb-0310-9956-ffa450edef68> | 2009-07-15 08:39:34 +0000 |
commit | 713fe52552b5ed11a10af8b10b1469556833f76d (patch) | |
tree | f937cfe98e18c04406451cf257d8b8ac3fdd894a /java/sca/modules | |
parent | 86765e75cfa1becfaa7485d497ca3459514f5882 (diff) |
Add support for SCA Properties - TUSCANY 3142
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@794186 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/sca/modules')
-rw-r--r-- | java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELImplementationProvider.java | 27 |
1 files changed, 18 insertions, 9 deletions
diff --git a/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELImplementationProvider.java b/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELImplementationProvider.java index 6ac9bc0a3f..82658aa2b7 100644 --- a/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELImplementationProvider.java +++ b/java/sca/modules/implementation-bpel-runtime/src/main/java/org/apache/tuscany/sca/implementation/bpel/ode/provider/BPELImplementationProvider.java @@ -52,6 +52,8 @@ public class BPELImplementationProvider implements ImplementationProvider { private EmbeddedODEServer odeServer; private TransactionManager txMgr; + + private ODEDeployment deployment; /** * Constructs a new BPEL Implementation. @@ -67,7 +69,15 @@ public class BPELImplementationProvider implements ImplementationProvider { // Configure the service and reference interfaces to use a DOM databinding // as it's what ODE expects - for (Service service: component.getServices()) { + for(Service service: implementation.getServices() ){ + service.getInterfaceContract().getInterface().resetDataBinding(DOMDataBinding.NAME); + } // end for + + for(Reference reference: implementation.getReferences() ) { + reference.getInterfaceContract().getInterface().resetDataBinding(DOMDataBinding.NAME); + } // end for + + for (Service service: component.getServices()) { //TODO - MJE, 06/06/2009 - we can eventually remove the reset of the service interface // contract and leave it to the Endpoints only service.getInterfaceContract().getInterface().resetDataBinding(DOMDataBinding.NAME); @@ -118,23 +128,20 @@ public class BPELImplementationProvider implements ImplementationProvider { // deploy the process if (odeServer.isInitialized()) { + deployment = new ODEDeployment( deploymentDir ); try { - //txMgr.begin(); odeServer.registerTuscanyRuntimeComponent(implementation.getProcess(), component); - // Replaced by Mike Edwards 23/05/2008 - //odeServer.deploy(new ODEDeployment(deploymentDir)); - odeServer.deploy(new ODEDeployment(deploymentDir), implementation ); - //txMgr.commit(); + + odeServer.deploy(deployment, implementation, component ); } catch (Exception e) { e.printStackTrace(); - //txMgr.rollback(); } } } catch (ODEInitializationException inite) { throw new RuntimeException("BPEL Component Type Implementation : Error initializing embedded ODE server " + inite.getMessage(), inite); } catch(Exception e) { - throw new RuntimeException("BPEl Component Type Implementation initialization failure : " + e.getMessage(), e); + throw new RuntimeException("BPEL Component Type Implementation initialization failure : " + e.getMessage(), e); } } @@ -143,8 +150,10 @@ public class BPELImplementationProvider implements ImplementationProvider { __log.info("Stopping " + component.getName()); } + odeServer.undeploy(deployment); + if (odeServer.isInitialized()) { - // start ode server + // stop ode server odeServer.stop(); } |