Author: objectiser Date: 2009-10-28 10:30:33 -0400 (Wed, 28 Oct 2009) New Revision: 208 Removed: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbmq-queue-service.xml trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbossesb-properties.xml trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jndi.properties trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/juddi.properties trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/log4j.xml Modified: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jboss-esb.xml trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java Log: Remove unnecessary files from esb test, and cleanup BPELEngineImpl to remove commented out code. Deleted: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbmq-queue-service.xml =================================================================== --- trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbmq-queue-service.xml 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbmq-queue-service.xml 2009-10-28 14:30:33 UTC (rev 208) @@ -1,21 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<server> - <mbean code="org.jboss.mq.server.jmx.Queue" - name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_bpel_helloworld_Request_esb"> - <depends optional-attribute-name="DestinationManager"> - jboss.mq:service=DestinationManager - </depends> - </mbean> - <mbean code="org.jboss.mq.server.jmx.Queue" - name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_bpel_helloworld_Request_esb_reply"> - <depends optional-attribute-name="DestinationManager"> - jboss.mq:service=DestinationManager - </depends> - </mbean> - <mbean code="org.jboss.mq.server.jmx.Queue" - name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_bpel_helloworld_Request_gw"> - <depends optional-attribute-name="DestinationManager"> - jboss.mq:service=DestinationManager - </depends> - </mbean> -</server> Modified: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jboss-esb.xml =================================================================== --- trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jboss-esb.xml 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jboss-esb.xml 2009-10-28 14:30:33 UTC (rev 208) @@ -43,6 +43,9 @@ </action> <!-- The next action is for Continuous Integration testing --> <action name="testStore" class="org.jboss.soa.esb.actions.TestMessageStore"/> + <action name="action4" class="org.jboss.soa.esb.actions.SystemPrintln"> + <property name="printfull" value="true"/> + </action> </actions> </service> </services> Deleted: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbossesb-properties.xml =================================================================== --- trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbossesb-properties.xml 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jbossesb-properties.xml 2009-10-28 14:30:33 UTC (rev 208) @@ -1,86 +0,0 @@ -<?xml version="1.0" encoding="ISO-8859-1"?> -<!-- - JBoss, Home of Professional Open Source - Copyright 2006, JBoss Inc., and others contributors as indicated - by the @authors tag. All rights reserved. - See the copyright.txt in the distribution for a - full listing of individual contributors. - This copyrighted material is made available to anyone wishing to use, - modify, copy, or redistribute it subject to the terms and conditions - of the GNU Lesser General Public License, v. 2.1. - This program is distributed in the hope that it will be useful, but WITHOUT A - WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A - PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. - You should have received a copy of the GNU Lesser General Public License, - v.2.1 along with this distribution; if not, write to the Free Software - Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, - MA 02110-1301, USA. - - (C) 2005-2006, - @author JBoss Inc. ---> -<!-- $Id: jbossesb-unittest-properties.xml $ --> -<!-- - These options are described in the JBossESB manual. - Defaults are provided here for convenience only. - - Please read through this file prior to using the system, and consider - updating the specified entries. ---> -<esb - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:noNamespaceSchemaLocation="jbossesb-1_0.xsd"> - <properties name="core"> - <property name="org.jboss.soa.esb.jndi.server.type" value="jboss"/> - <property name="org.jboss.soa.esb.jndi.server.url" value="localhost"/> - <property name="org.jboss.soa.esb.persistence.connection.factory" value="org.jboss.internal.soa.esb.persistence.format.MessageStoreFactoryImpl"/> - <property name="jboss.esb.invm.scope.default" value="NONE"/> - </properties> - <properties name="registry"> - <property name="org.jboss.soa.esb.registry.queryManagerURI" - value="jnp://localhost:1099/InquiryService?org.apache.juddi.registry.rmi.Inquiry#inquire"/> - <property name="org.jboss.soa.esb.registry.lifeCycleManagerURI" - value="jnp://localhost:1099/PublishService?org.apache.juddi.registry.rmi.Publish#publish" /> - <property name="org.jboss.soa.esb.registry.implementationClass" - value="org.jboss.internal.soa.esb.services.registry.JAXRRegistryImpl"/> - <property name="org.jboss.soa.esb.registry.factoryClass" - value="org.apache.ws.scout.registry.ConnectionFactoryImpl"/> - <property name="org.jboss.soa.esb.registry.user" - value="jbossesb"/> - <property name="org.jboss.soa.esb.registry.password" - value="password"/> - <!-- the following parameter is scout specific to set the type of communication between scout and the UDDI (embedded, rmi, soap) --> - <property name="org.jboss.soa.esb.scout.proxy.transportClass" - value="org.apache.ws.scout.transport.RMITransport"/> - </properties> - <properties name="transports" depends="core"> - <property name="org.jboss.soa.esb.mail.smtp.host" value="localhost"/> - <property name="org.jboss.soa.esb.mail.smtp.user" value="jbossesb"/> - <property name="org.jboss.soa.esb.mail.smtp.password" value=""/> - <property name="org.jboss.soa.esb.mail.smtp.port" value="25"/> - </properties> - <properties name="connection"> - <property name="min-pool-size" value="5"/> - <property name="max-pool=size" value="10"/> - <property name="blocking-timeout-millis" value="5000"/> - <property name="abandoned-connection-timeout" value="10000"/> - <property name="abandoned-connection-time-interval" value="30000"/> - </properties> - <properties name="dbstore"> - <property name="org.jboss.soa.esb.persistence.db.connection.url" value="jdbc:hsqldb:hsql://localhost:9001/"/> - <property name="org.jboss.soa.esb.persistence.db.jdbc.driver" value="org.hsqldb.jdbcDriver"/> - <property name="org.jboss.soa.esb.persistence.db.user" value="sa"/> - <property name="org.jboss.soa.esb.persistence.db.pwd" value=""/> - <property name="org.jboss.soa.esb.persistence.db.pool.initial.size" value="2"/> - <property name="org.jboss.soa.esb.persistence.db.pool.min.size" value="2"/> - <property name="org.jboss.soa.esb.persistence.db.pool.max.size" value="5"/> - <!--table managed by pool to test for valid connections - created by pool automatically --> - <property name="org.jboss.soa.esb.persistence.db.pool.test.table" value="pooltest"/> - <!-- # of milliseconds to timeout waiting for a connection from pool --> - <property name="org.jboss.soa.esb.persistence.db.pool.timeout.millis" value="5000"/> - <property name="org.jboss.soa.esb.persistence.db.conn.manager" value="org.jboss.internal.soa.esb.persistence.manager.StandaloneConnectionManager"/> - </properties> - <properties name="messagerouting"> - <property name="org.jboss.soa.esb.routing.cbrClass" value="org.jboss.internal.soa.esb.services.routing.cbr.JBossRulesRouter"/> - </properties> -</esb> Deleted: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jndi.properties =================================================================== --- trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jndi.properties 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/jndi.properties 2009-10-28 14:30:33 UTC (rev 208) @@ -1,5 +0,0 @@ -java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory -java.naming.provider.url=jnp://localhost:1099 -java.naming.factory.url.pkgs=org.jboss.naming -java.naming.factory.url.pkgs=org.jnp.interfaces - Deleted: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/juddi.properties =================================================================== --- trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/juddi.properties 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/juddi.properties 2009-10-28 14:30:33 UTC (rev 208) @@ -1,69 +0,0 @@ -# jUDDI Registry Properties (used by RegistryServer) -# see http://www.juddi.org for more information - -# The UDDI Operator Name -juddi.operatorName = jUDDI.org - -# The i18n locale default codes -juddi.i18n.languageCode = en -juddi.i18n.countryCode = US - -# The UDDI DiscoveryURL Prefix -juddi.discoveryURL = http://localhost:8080/juddi/uddiget.jsp? - -# The UDDI Operator Contact Email Address -juddi.operatorEmailAddress = admin(a)juddi.org - -# The maximum name size and maximum number -# of name elements allows in several of the -# FindXxxx and SaveXxxx UDDI functions. -juddi.maxNameLength=255 -juddi.maxNameElementsAllowed=5 - -# The maximum number of UDDI artifacts allowed -# per publisher. A value of '-1' indicates any -# number of artifacts is valid (These values can be -# overridden at the individual publisher level). -juddi.maxBusinessesPerPublisher=25 -juddi.maxServicesPerBusiness=20 -juddi.maxBindingsPerService=10 -juddi.maxTModelsPerPublisher=100 - -# jUDDI Authentication module to use -juddi.auth = org.apache.juddi.auth.DefaultAuthenticator - -# jUDDI DataStore module currently to use -juddi.dataStore = org.apache.juddi.datastore.jdbc.JDBCDataStore - -# use a dataSource (if set to false a direct -# jdbc connection will be used. -juddi.isUseDataSource=false -juddi.jdbcDriver=com.mysql.jdbc.Driver -juddi.jdbcUrl=jdbc:mysql://localhost:3306/juddi -juddi.jdbcUsername=root -juddi.jdbcPassword=admin -# jUDDI DataSource to use -# juddi.dataSource=java:comp/env/jdbc/MySqlDS - -# jUDDI UUIDGen implementation to use -juddi.uuidgen = org.apache.juddi.uuidgen.DefaultUUIDGen - -# jUDDI Cryptor implementation to use -juddi.cryptor = org.apache.juddi.cryptor.DefaultCryptor - -# jUDDI Validator to use -juddi.validator=org.apache.juddi.validator.DefaultValidator - -# jUDDI Proxy Properties (used by RegistryProxy) -juddi.proxy.adminURL = http://localhost:8080/juddi/admin -juddi.proxy.inquiryURL = http://localhost:8080/juddi/inquiry -juddi.proxy.publishURL = http://localhost:8080/juddi/publish -juddi.proxy.transportClass = org.apache.juddi.proxy.AxisTransport -juddi.proxy.securityProvider = com.sun.net.ssl.internal.ssl.Provider -juddi.proxy.protocolHandler = com.sun.net.ssl.internal.www.protocol - -# JNDI settings (used by RMITransport) -java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory -java.naming.provider.url=jnp://localhost:1099 -java.naming.factory.url.pkgs=org.jboss.naming - Deleted: trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/log4j.xml =================================================================== --- trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/log4j.xml 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/integration-tests/src/test/resources/samples/Quickstart_esb_bpel_hello_world/log4j.xml 2009-10-28 14:30:33 UTC (rev 208) @@ -1,79 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd"> - -<!-- ===================================================================== --> -<!-- --> -<!-- Log4j Configuration --> -<!-- --> -<!-- ===================================================================== --> - -<!-- $Id: log4j.xml,v 1.26.2.5 2005/09/15 09:31:02 dimitris Exp $ --> - -<!-- - | For more configuration infromation and examples see the Jakarta Log4j - | owebsite: http://jakarta.apache.org/log4j - --> - -<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/" debug="false"> - - <!-- ============================== --> - <!-- Append messages to the console --> - <!-- ============================== --> - - <appender name="CONSOLE" class="org.apache.log4j.ConsoleAppender"> - <errorHandler class="org.jboss.logging.util.OnlyOnceErrorHandler"/> - <param name="Target" value="System.out"/> - <param name="Threshold" value="INFO"/> - - <layout class="org.apache.log4j.PatternLayout"> - <!-- The default pattern: Date Priority [Category] Message\n --> - <param name="ConversionPattern" value="%d{ABSOLUTE} %-5p [%t][%c{1}] %m%n"/> - </layout> - </appender> - - <!-- ================================= --> - <!-- Preserve messages in a local file --> - <!-- ================================= --> - - <!-- A size based file rolling appender --> - <appender name="FILE" class="org.jboss.logging.appender.RollingFileAppender"> - <errorHandler class="org.jboss.logging.util.OnlyOnceErrorHandler"/> - <param name="File" value="./listener.log"/> - <param name="Append" value="false"/> - <param name="MaxFileSize" value="500KB"/> - <param name="MaxBackupIndex" value="1"/> - - <layout class="org.apache.log4j.PatternLayout"> - <param name="ConversionPattern" value="%d %-5p [%t][%c] %m%n"/> - </layout> - </appender> - - <!-- ================ --> - <!-- Limit categories --> - <!-- ================ --> - - <category name="org.jboss"> - <priority value="WARN"/> - </category> - <category name="org.jboss.soa.esb"> - <priority value="ERROR"/> - </category> - <category name="org.jboss.internal.soa.esb"> - <priority value="ERROR"/> - </category> - <category name="org.apache"> - <priority value="ERROR"/> - </category> - <category name="quickstart"> - <priority value="DEBUG"/> - </category> - <!-- ======================= --> - <!-- Setup the Root category --> - <!-- ======================= --> - - <root> - <appender-ref ref="CONSOLE"/> - <appender-ref ref="FILE"/> - </root> - -</log4j:configuration> Modified: trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java =================================================================== --- trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java 2009-10-28 13:39:21 UTC (rev 207) +++ trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java 2009-10-28 14:30:33 UTC (rev 208) @@ -199,10 +199,6 @@ throw new Exception(errorMsg); } - //if (outMsgContext != null) { - //SOAPEnvelope envelope = soapFactory.getDefaultEnvelope(); - //outMsgContext.setEnvelope(envelope); - // Hopefully we have a response __log.debug("Handling response for MEX " + odeMex); boolean commit = false; @@ -214,10 +210,6 @@ } try { // Refreshing the message exchange - //odeMex = (MyRoleMessageExchange) _server.getEngine().getMessageExchange(odeMex.getMessageExchangeId()); - //onResponse(odeMex, outMsgContext); - - // Refreshing the message exchange odeMex = (MyRoleMessageExchange) _bpelServer.getEngine().getMessageExchange(odeMex.getMessageExchangeId()); ret = onResponse(odeMex); @@ -258,76 +250,6 @@ odeMex.release(true); } - - - - - - /* - - MyRoleMessageExchange odeMex = null; - try { - // Creating mesage exchange - String messageId = new GUID().toString(); - odeMex = _bpelServer.createMessageExchange( - InvocationStyle.UNRELIABLE, service, operation, messageId - ); - - __log.debug("ODE routed to operation " + odeMex.getOperation() + " from service " + service); - - if (odeMex.getOperation() == null) { - String errmsg = "Call to " + service + "." + odeMex.getOperationName() + " was not routable."; - __log.error(errmsg); - throw new Exception(errmsg); - } - - // Preparing message to send to ODE - Message odeRequest = odeMex.createMessage(odeMex.getOperation().getInput().getMessage().getQName()); - //_converter.parseSoapRequest(odeRequest, msgContext.getEnvelope(), odeMex.getOperation()); - - odeRequest.setMessage(message); - - // TODO: Might need to store session id/epr of caller? - //readHeader(msgContext, odeMex); - - if (__log.isDebugEnabled()) { - __log.debug("Invoking ODE using MEX " + odeMex); - __log.debug("Message content: " + DOMUtils.domToString(odeRequest.getMessage())); - } - - odeMex.setRequest(odeRequest); - odeMex.setTimeout(resolveTimeout()); - - if(__log.isDebugEnabled()) __log.debug("Blocking invoke with mex " + odeMex.getMessageExchangeId() + "."); - - odeMex.invokeBlocking(); - - if (odeMex.getOperation().getOutput() != null) { - - // TODO: Need to check response type - i.e. could be fault, odeMex.getAckType() - - Message resp=odeMex.getResponse(); - - ret = resp.getMessage(); - - __log.debug("Returning: "+ret); - - } - } catch (java.util.concurrent.TimeoutException te) { - String errmsg = "Call to " + service + "." + odeMex.getOperationName() + " timed out(" + resolveTimeout() + " ms)."; - __log.error(errmsg, te); - throw new Exception(errmsg); - } catch (Exception e) { - __log.error("EXCEPTION", e); - - String errmsg = "Call to " + service + "." + odeMex.getOperationName() + " caused an exception."; - __log.error(errmsg, e); - throw new Exception(errmsg, e); - } finally { - // we cannot release ode mex here since it's outside of the transaction - } - */ - return(ret); } @@ -349,20 +271,6 @@ case FAILURE: if (__log.isDebugEnabled()) __log.debug("Failure response message: " + mex.getFault()); - - /* - OdeFault odeFault; - String beVerbose = _pconf.getEndpointProperties(_serviceRef).get(Properties.PROP_MEX_FAILURE_VERBOSE); - // default is true - if (beVerbose == null || Boolean.valueOf(beVerbose)) { - odeFault = _converter.createOdeFault(mex.getFaultExplanation(), mex.getFaultResponse()); - } else { - odeFault = new OdeFault("Message exchange failure."); - odeFault.setDetail(null); - odeFault.setStackTrace(new StackTraceElement[]{}); - } - throw odeFault; - */ __log.error("Failure details: "+mex.getFaultResponse()); throw new Exception("Failure response message: "+mex.getFault()+" : "+mex.getFaultExplanation()); @@ -398,16 +306,6 @@ } private long resolveTimeout() { - /* _serviceRef is a WSAEndpoint - not sure if we need to provide this? - String timeout = _pconf.getEndpointProperties(_serviceRef).get(Properties.PROP_MEX_TIMEOUT); - if (timeout != null) { - try { - return Long.parseLong(timeout); - } catch (NumberFormatException e) { - if(__log.isWarnEnabled()) __log.warn("Mal-formatted Property: ["+ Properties.PROP_MEX_TIMEOUT+"="+timeout+"] Default value ("+Properties.DEFAULT_MEX_TIMEOUT+") will be used"); - } - } - */ return Properties.DEFAULT_MEX_TIMEOUT; } @@ -422,7 +320,7 @@ __log.error("Failed to load properties", e); } - __log.info("ODE PROPS="+props); + __log.debug("ODE PROPS="+props); _odeConfig = new OdeConfigProperties(props, "bpel."); @@ -496,7 +394,7 @@ } protected void initDAO() throws Exception { - __log.info("USING DAO: "+_odeConfig.getDAOConnectionFactory()); + __log.debug("USING DAO: "+_odeConfig.getDAOConnectionFactory()); try { _daoCF = _db.createDaoCF(); } catch (Exception ex) { @@ -524,32 +422,6 @@ return scheduler; } - /* ODE2 version - protected void initBpelServer(EndpointReferenceContextImpl eprContext) { - if (__log.isDebugEnabled()) { - __log.debug("ODE initializing"); - } - - _bpelServer = new BpelServerImpl(); - _scheduler = createScheduler(); - _scheduler.setJobProcessor(_bpelServer); - - _bpelServer.setDaoConnectionFactory(_daoCF); - _bpelServer.setEndpointReferenceContext(eprContext); - _bpelServer.setMessageExchangeContext(new MessageExchangeContextImpl(this)); - _bpelServer.setBindingContext(new JAXWSBindingContext(this)); - _bpelServer.setScheduler(_scheduler); - _bpelServer.setTransactionManager(_txMgr); - if (_odeConfig.isDehydrationEnabled()) { - CountLRUDehydrationPolicy dehy = new CountLRUDehydrationPolicy(); - // dehy.setProcessMaxAge(10000); - _bpelServer.setDehydrationPolicy(dehy); - } - _bpelServer.setConfigProperties(_odeConfig); - _bpelServer.init(); - } - */ - private void initBpelServer(EndpointReferenceContextImpl eprContext) { if (__log.isDebugEnabled()) { __log.debug("ODE initializing"); @@ -617,7 +489,7 @@ String listenerCN = tokenizer.nextToken(); try { _bpelServer.registerBpelEventListener((BpelEventListener) Class.forName(listenerCN).newInstance()); - __log.info("REGISTERED EVENT LISTENER: "+listenerCN); + __log.debug("REGISTERED EVENT LISTENER: "+listenerCN); } catch (Exception e) { __log.warn("Couldn't register the event listener " + listenerCN + ", the class couldn't be " + "loaded properly: " + e); @@ -634,7 +506,7 @@ String interceptorCN = tokenizer.nextToken(); try { _bpelServer.registerMessageExchangeInterceptor((MessageExchangeInterceptor) Class.forName(interceptorCN).newInstance()); - __log.info("MESSAGE EXCHANGE INTERCEPTOR REGISTERED: "+interceptorCN); + __log.debug("MESSAGE EXCHANGE INTERCEPTOR REGISTERED: "+interceptorCN); } catch (Exception e) { __log.warn("Couldn't register the event listener " + interceptorCN + ", the class couldn't be " + "loaded properly: " + e); @@ -643,45 +515,6 @@ } } - /* - private void registerExtensionActivityBundles() { - String extensionsRTStr = _odeConfig.getExtensionActivityBundlesRT(); - String extensionsValStr = _odeConfig.getExtensionActivityBundlesValidation(); - if (extensionsRTStr != null) { - // TODO replace StringTokenizer by regex - for (StringTokenizer tokenizer = new StringTokenizer(extensionsRTStr, ",;"); tokenizer.hasMoreTokens();) { - String bundleCN = tokenizer.nextToken(); - try { - // instantiate bundle - ExtensionBundleRuntime bundleRT = (ExtensionBundleRuntime) Class.forName(bundleCN).newInstance(); - // register extension bundle (BPEL server) - _bpelServer.registerExtensionBundle(bundleRT); - } catch (Exception e) { - __log.warn("Couldn't register the extension bundle runtime " + bundleCN + ", the class couldn't be " + - "loaded properly."); - } - } - } - if (extensionsValStr != null) { - Map<QName, ExtensionValidator> validators = new HashMap<QName, ExtensionValidator>(); - for (StringTokenizer tokenizer = new StringTokenizer(extensionsValStr, ",;"); tokenizer.hasMoreTokens();) { - String bundleCN = tokenizer.nextToken(); - try { - // instantiate bundle - ExtensionBundleValidation bundleVal = (ExtensionBundleValidation) Class.forName(bundleCN).newInstance(); - //add validators - validators.putAll(bundleVal.getExtensionValidators()); - } catch (Exception e) { - __log.warn("Couldn't register the extension bundle validator " + bundleCN + ", the class couldn't be " + - "loaded properly."); - } - } - // register extension bundle (BPEL store) - _store.setExtensionValidators(validators); - } - } - */ - private void registerExternalVariableModules() { JdbcExternalVariableModule jdbcext; jdbcext = new JdbcExternalVariableModule(); @@ -692,36 +525,7 @@ private void handleEvent(ProcessStoreEvent pse) { - // TODO: TEAM_ODE - need to inform BPELEngine listeners of new process, in case - // they need to do some dynamic registration of the service interface - // (e.g. jbossws) - // THIS could be done in the BindingContextImpl - as part of - // activating and deactivating the endpoint - so the BindingContextImpl - // invokes the appropriate Transport Layer implementation(s) to register/activate - // the endpoint - - /* __log.debug("Process store event: " + pse); - switch (pse.type) { - case ACTIVATED: - case RETIRED: - // bounce the process - _bpelServer.unregister(pse.pid); - ProcessConf pconf = _store.getProcessConfiguration(pse.pid); - if (pconf != null) _bpelServer.register(pconf); - else __log.debug("slighly odd: recevied event " + pse + " for process not in store!"); - break; - case DISABLED: - case UNDEPLOYED: - _bpelServer.unregister(pse.pid); - _bpelServer.cleanupProcess(pse.pid); - break; - default: - __log.debug("Ignoring store event: " + pse); - } - */ - - __log.debug("Process store event: " + pse); ProcessConf pconf = _store.getProcessConfiguration(pse.pid); switch (pse.type) { case DEPLOYED: