[jboss-svn-commits] JBL Code SVN: r11368 - in labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1: src and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Thu Apr 26 13:48:39 EDT 2007
Author: estebanschifman
Date: 2007-04-26 13:48:39 -0400 (Thu, 26 Apr 2007)
New Revision: 11368
Added:
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestBpmProcessor.java
Removed:
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/process_01.xml
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/jboss-esb.xml
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/simpleProcessDefinition.xml
Log:
Modified: labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/build.xml 2007-04-26 17:47:31 UTC (rev 11367)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/build.xml 2007-04-26 17:48:39 UTC (rev 11368)
@@ -10,6 +10,7 @@
<property name="jbpm.services.build.dir" value="${product.dir}/build/services/jbpm.esb" />
<property name="esb.archive.name" value="jbpm_simple1" />
+ <property name="esb.deploy.dir" value="${product.dir}/build/jbossesb-server-4.2.MR1/server/default/deploy" />
<available file="${jbpm.services.build.dir}" type="dir" property="jbpm.isBuilt"/>
<fail unless="jbpm.isBuilt"
@@ -33,10 +34,8 @@
</target>
<target name="esb" depends="prepare">
- <delete file="build/${esb.archive.name}.esb/META-INF/jboss-esb.xml" />
- <copy todir="build/${esb.archive.name}.esb/META-INF">
- <fileset dir="${basedir}" includes="jboss-esb.xml" />
- </copy>
+ <copy overwrite="true" file="jboss-esb.xml" todir="build/${esb.archive.name}.esb/META-INF" />
+ <copy file="simpleProcessDefinition.xml" todir="build/${esb.archive.name}.esb" />
</target>
<target name="runtest" depends="compile"
@@ -49,11 +48,23 @@
</java>
</target>
- <target name="quickstart-specific-deploys">
- <echo message="deploying ${esb,archive.name}.esb to ${org.jboss.esb.server.deploy.dir}" />
- <copy todir="${org.jboss.esb.server.deploy.dir}/${esb.archive.name}.esb" >
- <fileset dir="build/${esb.archive.name}.esb"/>
+ <target name="deploy" depends="esb">
+ <description>deploy will deploy the Quickstart .esb archive to JBoss ESB Server
+ </description>
+ <echo>Deploying Quickstart to JBoss ESB Server...</echo>
+
+ <mkdir dir="${esb.deploy.dir}/${esb.archive.name}.esb" />
+ <copy overwrite="true" todir="${esb.deploy.dir}/${esb.archive.name}.esb">
+ <fileset dir="${build.dir}/${esb.archive.name}.esb" />
</copy>
+
+ <echo message='${line.separator}******************' />
+ <echo>Quickstart deployed to target JBoss ESB Server at '${esb.deploy.dir}'.</echo>
+ <echo>1. Check your ESB Server console to make sure the deployment was executed without errors.</echo>
+ <echo>2. Run 'ant runtest' to run the Quickstart.</echo>
+ <echo>3. Check your ESB Server console again. The Quickstart should have produced some output.</echo>
+ <echo message='******************' />
+
</target>
-
+
</project>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/jboss-esb.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/jboss-esb.xml 2007-04-26 17:47:31 UTC (rev 11367)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/jboss-esb.xml 2007-04-26 17:48:39 UTC (rev 11368)
@@ -3,17 +3,12 @@
<providers>
<fs-provider name="FSprovider1">
- <fs-bus busid="helloFileChannel" >
+ <fs-bus busid="jbpmFileChannel" >
<fs-message-filter
- directory="/opt/jboss/esb/source/livetrunk/product/samples/quickstarts/helloworld_file_action/build/dirs/input"
- input-suffix=".dat"
- work-suffix=".esbWorking"
- post-delete="false"
- post-directory="/opt/jboss/esb/source/livetrunk/product/samples/quickstarts/helloworld_file_action/build/dirs/output"
- post-suffix=".sentToEsb"
- error-delete="false"
- error-directory="/opt/jboss/esb/source/livetrunk/product/samples/quickstarts/helloworld_file_action/build/dirs/error"
- error-suffix=".IN_ERROR"
+ directory="/tmp"
+ input-suffix=".toJbpmQs1"
+ post-delete="true"
+ error-delete="true"
/>
</fs-bus>
</fs-provider>
@@ -21,15 +16,14 @@
<services>
<service
- category="myCategory"
- name="myFileListener"
+ category="jbpmQsCat1"
+ name="jbpmQsName1"
description="Hello World File Action (esb listener)" >
<listeners>
- <fs-listener name="FileGateway"
- busidref="helloFileChannel"
+ <fs-listener name="JbpmQuickstart_1"
+ busidref="jbpmFileChannel"
maxThreads="1"
- is-gateway="true"
- poll-frequency-seconds="10"
+ poll-frequency-seconds="3"
/>
</listeners>
<actions>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/simpleProcessDefinition.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/simpleProcessDefinition.xml 2007-04-26 17:47:31 UTC (rev 11367)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/simpleProcessDefinition.xml 2007-04-26 17:48:39 UTC (rev 11368)
@@ -1,17 +1,13 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<process-definition
- xmlns="urn:jbpm.org:jpdl-3.1"
- name="simple">
- <start-state name="start">
- <transition name="to_state" to="first">
-
- </transition>
- </start-state>
- <state name="first">
- <transition name="to_end" to="end">
-
- </transition>
- </state>
- <end-state name="end"></end-state>
+<?xml version="1.0" encoding="UTF-8"?>
+
+<process-definition
+ xmlns="urn:jbpm.org:jpdl-3.1"
+ name="simple">
+ <start-state name="start">
+ <transition name="to_state" to="first" />
+ </start-state>
+ <state name="first">
+ <transition name="to_end" to="end" />
+ </state>
+ <end-state name="end"></end-state>
</process-definition>
\ No newline at end of file
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/process_01.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/process_01.xml 2007-04-26 17:47:31 UTC (rev 11367)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/process_01.xml 2007-04-26 17:48:39 UTC (rev 11368)
@@ -1,13 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<process-definition
- xmlns="urn:jbpm.org:jpdl-3.1"
- name="simple">
- <start-state name="start">
- <transition name="to_state" to="first" />
- </start-state>
- <state name="first">
- <transition name="to_end" to="end" />
- </state>
- <end-state name="end"></end-state>
-</process-definition>
\ No newline at end of file
Copied: labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestBpmProcessor.java (from rev 11358, labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java)
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestBpmProcessor.java (rev 0)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestBpmProcessor.java 2007-04-26 17:48:39 UTC (rev 11368)
@@ -0,0 +1,202 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY 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 along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package quickstart.jbpm_simple1.test;
+
+import static org.junit.Assert.assertTrue;
+
+import java.io.ByteArrayOutputStream;
+import java.io.InputStream;
+import java.io.PrintStream;
+
+import org.apache.log4j.Logger;
+import org.jboss.soa.esb.common.Environment;
+import org.jboss.soa.esb.common.ModulePropertyManager;
+import org.jboss.soa.esb.listeners.message.Invoker;
+import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.services.jbpm.Constants;
+import org.jboss.soa.esb.services.jbpm.util.Helper;
+import org.jbpm.graph.exe.Token;
+
+import com.arjuna.common.util.propertyservice.PropertyManager;
+
+public class TestBpmProcessor
+{
+
+ static Logger _logger = Logger.getLogger(TestBpmProcessor.class);
+
+ private static final String TEST_SVC_CATEGORY ="categoryJbpmService";
+ private static final String TEST_SVC_NAME ="nameJbpmService";
+ private static final String TEST_PROCESS_NAME ="simple";
+
+ public static void main(String[] args) throws Exception
+ {
+ new TestBpmProcessor().run();
+ }
+
+
+
+ public void run() throws Exception
+ {
+
+ setupRegistry();
+
+ long instanceId=0 , tokenId=0;
+ Constants.OpCode opCode = null;
+ Message request, response;
+
+ _logger.info("testFullProcessLifecycle() invoked");
+ try
+ {
+ opCode = Constants.OpCode.DeployProcessDefinition;
+ request = Helper.commandMessageTemplate();
+ Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
+ Helper.setStringValue(request, Constants.PROCESS_DEFINITION_XML
+ , getProcessDefinitionXml("process_01.xml"));
+
+ response = invokeJbpm(request);
+ _logger.info(dumpResponse(response, opCode));
+ assertTrue(Constants.RETCODE_OK.equals(Helper.getStringValue(response, Constants.RETURN_CODE)));
+
+ opCode = Constants.OpCode.NewProcessInstanceCommand;
+ request = Helper.commandMessageTemplate();
+ Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
+ Helper.setStringValue(request, Constants.PROCESS_DEFINITION_NAME, TEST_PROCESS_NAME);
+ response = invokeJbpm(request);
+ _logger.info(dumpResponse(response, opCode));
+ assertTrue(Constants.RETCODE_OK.equals(Helper.getStringValue(response, Constants.RETURN_CODE)));
+
+ instanceId = Helper.getLongValue(response,Constants.PROCESS_INSTANCE_ID);
+ tokenId = Helper.getLongValue(response,Constants.TOKEN_ID);
+ boolean signalToken = true;
+ for (boolean continueLooping = true; continueLooping;)
+ {
+ opCode = Constants.OpCode.SignalCommand;
+ // for this test, alternatively signal: token - process - token ...
+
+ request = Helper.commandMessageTemplate();
+ Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
+ if (signalToken)
+ Helper.setLongValue(request, Constants.TOKEN_ID, tokenId);
+ else
+ Helper.setLongValue(request, Constants.PROCESS_INSTANCE_ID, instanceId);
+ response = invokeJbpm(request);
+ signalToken = ! signalToken;
+
+ if (null!=response)
+ _logger.info(dumpResponse(response, opCode));
+ else
+ _logger.info("Response was not received");
+ assertTrue(Constants.RETCODE_OK.equals(Helper.getObjectValue(response, Constants.RETURN_CODE)));
+
+ Token token = (Token)Helper.getObjectValue(response, Constants.JBPM_RETURN_OBJECT);
+ if (token.hasEnded())
+ break;
+ instanceId = Helper.getLongValue(response,Constants.PROCESS_INSTANCE_ID);
+ tokenId = Helper.getLongValue(response,Constants.TOKEN_ID);
+ }
+
+ }
+ catch (Exception _ex)
+ {
+ _ex.printStackTrace();
+ assertTrue(false);
+ }
+
+ }
+
+ /**
+ * Invocation of this method should be unnecessary.
+ * Had to invoke it because I had trouble to have the properties loaded from jbossesb-properties.xml
+ * Once that is solved, you can get rid of the invocation to this method (up in the run() )
+ */
+ protected void setupRegistry() {
+ PropertyManager mgr = null;
+
+ mgr = ModulePropertyManager.getPropertyManager("registry");
+ mgr.setProperty(Environment.REGISTRY_IMPEMENTATION_CLASS,"org.jboss.internal.soa.esb.services.registry.JAXRRegistryImpl");
+ mgr.setProperty(Environment.REGISTRY_QUERY_MANAGER_URI,"jnp://localhost:1099/InquiryService?org.apache.juddi.registry.rmi.Inquiry#inquire");
+ mgr.setProperty(Environment.REGISTRY_LIFECYCLE_MANAGER_URI,"jnp://localhost:1099/PublishService?org.apache.juddi.registry.rmi.Publish#publish");
+ mgr.setProperty(Environment.REGISTRY_FACTORY_CLASS,"org.apache.ws.scout.registry.ConnectionFactoryImpl");
+ mgr.setProperty(Environment.REGISTRY_SCOUT_TRANSPORT_CLASS,"org.apache.ws.scout.transport.RMITransport");
+ mgr.setProperty(Environment.REGISTRY_USER,"jbossesb");
+ mgr.setProperty(Environment.REGISTRY_PASSWORD,"password");
+ System.setProperty("javax.xml.registry.ConnectionFactoryClass", "org.apache.ws.scout.registry.ConnectionFactoryImpl");
+
+ mgr = ModulePropertyManager.getPropertyManager(ModulePropertyManager.CORE_MODULE) ;
+ mgr.setProperty(Environment.REGISTRY_FILE_HELPER_DIR, "/tmp") ;
+
+ }
+
+ protected Message invokeJbpm(Message request) throws Exception
+ {
+ return Invoker.invokeAndAwaitResponse(request,TEST_SVC_CATEGORY, TEST_SVC_NAME, 20000);
+ }
+
+
+ protected String getProcessDefinitionXml(String pFileName) throws Exception
+ {
+ InputStream in = this.getClass().getClassLoader().getResourceAsStream(pFileName);
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+ byte[]ba = new byte[1000];
+ int iQ = -1;
+ while (-1<(iQ=in.read(ba)))
+ if (iQ>0) out.write(ba,0,iQ);
+ return out.toString();
+ }
+
+ public static String dumpResponse(Message message, Constants.OpCode opCode)
+ {
+ StringBuilder sb = new StringBuilder("\nInvoked: ").append(opCode.toString()).append("\n");
+ if (null==message)
+ return sb.append(" - No response received").toString();
+ sb.append(getObject(message,Constants.RETURN_CODE));
+ sb.append(getObject(message,Constants.ERROR_MESSAGE));
+ sb.append(getObject(message,Constants.EXCEPTION));
+ sb.append(getObject(message,Constants.ACTOR_ID));
+ sb.append(getObject(message,Constants.ACTOR_NAMES_ARRAY));
+ sb.append(getObject(message,Constants.CURRENT_NODE_NAME));
+ sb.append(getObject(message,Constants.JBPM_RETURN_OBJECT));
+ sb.append(getObject(message,Constants.PROCESS_DEFINITION_NAME));
+ sb.append(getObject(message,Constants.PROCESS_DEFINITION_VERSION));
+ sb.append(getObject(message,Constants.PROCESS_INSTANCE_ID));
+ sb.append(getObject(message,Constants.TASK_INSTANCE_ID));
+ sb.append(getObject(message,Constants.TOKEN_ID));
+ sb.append(getObject(message,Constants.HAS_ENDED));
+ return sb.append("_______________________________________________________________________")
+ .toString();
+ }
+
+ public static String getObject(Message message, String key)
+ {
+ Object obj = message.getBody().get(key);
+ if (null==obj)
+ return "";
+ if (!(obj instanceof Exception))
+ return key+" = "+obj.toString()+"\n";
+ ByteArrayOutputStream ba = new ByteArrayOutputStream();
+ ((Exception)obj).printStackTrace(new PrintStream(ba));
+ return key+" = "+obj.toString()+"\n"+ba.toString();
+ }
+
+
+}
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java 2007-04-26 17:47:31 UTC (rev 11367)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java 2007-04-26 17:48:39 UTC (rev 11368)
@@ -1,202 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2006, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY 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 along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package quickstart.jbpm_simple1.test;
-
-import static org.junit.Assert.assertTrue;
-
-import java.io.ByteArrayOutputStream;
-import java.io.InputStream;
-import java.io.PrintStream;
-
-import org.apache.log4j.Logger;
-import org.jboss.soa.esb.common.Environment;
-import org.jboss.soa.esb.common.ModulePropertyManager;
-import org.jboss.soa.esb.listeners.message.Invoker;
-import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.services.jbpm.Constants;
-import org.jboss.soa.esb.services.jbpm.util.Helper;
-import org.jbpm.graph.exe.Token;
-
-import com.arjuna.common.util.propertyservice.PropertyManager;
-
-public class TestCommandMessages
-{
-
- static Logger _logger = Logger.getLogger(TestCommandMessages.class);
-
- private static final String TEST_SVC_CATEGORY ="categoryJbpmService";
- private static final String TEST_SVC_NAME ="nameJbpmService";
- private static final String TEST_PROCESS_NAME ="simple";
-
- public static void main(String[] args) throws Exception
- {
- new TestCommandMessages().run();
- }
-
-
-
- public void run() throws Exception
- {
-
- setupRegistry();
-
- long instanceId=0 , tokenId=0;
- Constants.OpCode opCode = null;
- Message request, response;
-
- _logger.info("testFullProcessLifecycle() invoked");
- try
- {
- opCode = Constants.OpCode.DeployProcessDefinition;
- request = Helper.commandMessageTemplate();
- Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
- Helper.setStringValue(request, Constants.PROCESS_DEFINITION_XML
- , getProcessDefinitionXml("process_01.xml"));
-
- response = invokeJbpm(request);
- _logger.info(dumpResponse(response, opCode));
- assertTrue(Constants.RETCODE_OK.equals(Helper.getStringValue(response, Constants.RETURN_CODE)));
-
- opCode = Constants.OpCode.NewProcessInstanceCommand;
- request = Helper.commandMessageTemplate();
- Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
- Helper.setStringValue(request, Constants.PROCESS_DEFINITION_NAME, TEST_PROCESS_NAME);
- response = invokeJbpm(request);
- _logger.info(dumpResponse(response, opCode));
- assertTrue(Constants.RETCODE_OK.equals(Helper.getStringValue(response, Constants.RETURN_CODE)));
-
- instanceId = Helper.getLongValue(response,Constants.PROCESS_INSTANCE_ID);
- tokenId = Helper.getLongValue(response,Constants.TOKEN_ID);
- boolean signalToken = true;
- for (boolean continueLooping = true; continueLooping;)
- {
- opCode = Constants.OpCode.SignalCommand;
- // for this test, alternatively signal: token - process - token ...
-
- request = Helper.commandMessageTemplate();
- Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
- if (signalToken)
- Helper.setLongValue(request, Constants.TOKEN_ID, tokenId);
- else
- Helper.setLongValue(request, Constants.PROCESS_INSTANCE_ID, instanceId);
- response = invokeJbpm(request);
- signalToken = ! signalToken;
-
- if (null!=response)
- _logger.info(dumpResponse(response, opCode));
- else
- _logger.info("Response was not received");
- assertTrue(Constants.RETCODE_OK.equals(Helper.getObjectValue(response, Constants.RETURN_CODE)));
-
- Token token = (Token)Helper.getObjectValue(response, Constants.JBPM_RETURN_OBJECT);
- if (token.hasEnded())
- break;
- instanceId = Helper.getLongValue(response,Constants.PROCESS_INSTANCE_ID);
- tokenId = Helper.getLongValue(response,Constants.TOKEN_ID);
- }
-
- }
- catch (Exception _ex)
- {
- _ex.printStackTrace();
- assertTrue(false);
- }
-
- }
-
- /**
- * Invocation of this method should be unnecessary.
- * Had to invoke it because I had trouble to have the properties loaded from jbossesb-properties.xml
- * Once that is solved, you can get rid of the invocation to this method (up in the run() )
- */
- protected void setupRegistry() {
- PropertyManager mgr = null;
-
- mgr = ModulePropertyManager.getPropertyManager("registry");
- mgr.setProperty(Environment.REGISTRY_IMPEMENTATION_CLASS,"org.jboss.internal.soa.esb.services.registry.JAXRRegistryImpl");
- mgr.setProperty(Environment.REGISTRY_QUERY_MANAGER_URI,"jnp://localhost:1099/InquiryService?org.apache.juddi.registry.rmi.Inquiry#inquire");
- mgr.setProperty(Environment.REGISTRY_LIFECYCLE_MANAGER_URI,"jnp://localhost:1099/PublishService?org.apache.juddi.registry.rmi.Publish#publish");
- mgr.setProperty(Environment.REGISTRY_FACTORY_CLASS,"org.apache.ws.scout.registry.ConnectionFactoryImpl");
- mgr.setProperty(Environment.REGISTRY_SCOUT_TRANSPORT_CLASS,"org.apache.ws.scout.transport.RMITransport");
- mgr.setProperty(Environment.REGISTRY_USER,"jbossesb");
- mgr.setProperty(Environment.REGISTRY_PASSWORD,"password");
- System.setProperty("javax.xml.registry.ConnectionFactoryClass", "org.apache.ws.scout.registry.ConnectionFactoryImpl");
-
- mgr = ModulePropertyManager.getPropertyManager(ModulePropertyManager.CORE_MODULE) ;
- mgr.setProperty(Environment.REGISTRY_FILE_HELPER_DIR, "/tmp") ;
-
- }
-
- protected Message invokeJbpm(Message request) throws Exception
- {
- return Invoker.invokeAndAwaitResponse(request,TEST_SVC_CATEGORY, TEST_SVC_NAME, 20000);
- }
-
-
- protected String getProcessDefinitionXml(String pFileName) throws Exception
- {
- InputStream in = this.getClass().getClassLoader().getResourceAsStream(pFileName);
- ByteArrayOutputStream out = new ByteArrayOutputStream();
- byte[]ba = new byte[1000];
- int iQ = -1;
- while (-1<(iQ=in.read(ba)))
- if (iQ>0) out.write(ba,0,iQ);
- return out.toString();
- }
-
- public static String dumpResponse(Message message, Constants.OpCode opCode)
- {
- StringBuilder sb = new StringBuilder("\nInvoked: ").append(opCode.toString()).append("\n");
- if (null==message)
- return sb.append(" - No response received").toString();
- sb.append(getObject(message,Constants.RETURN_CODE));
- sb.append(getObject(message,Constants.ERROR_MESSAGE));
- sb.append(getObject(message,Constants.EXCEPTION));
- sb.append(getObject(message,Constants.ACTOR_ID));
- sb.append(getObject(message,Constants.ACTOR_NAMES_ARRAY));
- sb.append(getObject(message,Constants.CURRENT_NODE_NAME));
- sb.append(getObject(message,Constants.JBPM_RETURN_OBJECT));
- sb.append(getObject(message,Constants.PROCESS_DEFINITION_NAME));
- sb.append(getObject(message,Constants.PROCESS_DEFINITION_VERSION));
- sb.append(getObject(message,Constants.PROCESS_INSTANCE_ID));
- sb.append(getObject(message,Constants.TASK_INSTANCE_ID));
- sb.append(getObject(message,Constants.TOKEN_ID));
- sb.append(getObject(message,Constants.HAS_ENDED));
- return sb.append("_______________________________________________________________________")
- .toString();
- }
-
- public static String getObject(Message message, String key)
- {
- Object obj = message.getBody().get(key);
- if (null==obj)
- return "";
- if (!(obj instanceof Exception))
- return key+" = "+obj.toString()+"\n";
- ByteArrayOutputStream ba = new ByteArrayOutputStream();
- ((Exception)obj).printStackTrace(new PrintStream(ba));
- return key+" = "+obj.toString()+"\n"+ba.toString();
- }
-
-
-}
More information about the jboss-svn-commits
mailing list