[jboss-svn-commits] JBL Code SVN: r11190 - labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sat Apr 21 10:38:18 EDT 2007
Author: estebanschifman
Date: 2007-04-21 10:38:18 -0400 (Sat, 21 Apr 2007)
New Revision: 11190
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java
Log:
Use the standard JbpmTestUtil methods
Modified: 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-21 14:32:22 UTC (rev 11189)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java 2007-04-21 14:38:18 UTC (rev 11190)
@@ -33,6 +33,7 @@
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.actions.JbpmTestUtil;
import org.jboss.soa.esb.services.jbpm.util.Helper;
import org.jbpm.graph.exe.Token;
@@ -53,116 +54,78 @@
- public void run() throws Exception {
+ public void run() throws Exception
+ {
setupRegistry();
long instanceId=0 , tokenId=0;
- Exception excJbpm;
- Constants.OpCode opCode = null;
- Message request, response;
+ Constants.OpCode opCode = null;
+ Message request, response;
+
+ _logger.info("testFullProcessLifecycle() invoked");
+ try
+ {
+ request = Helper.commandMessageTemplate();
+ // CAUTION CAUTION CAUTION: please do NOT use the "DONOTUSE_createSchema" command
+ Helper.setStringValue(request, Constants.COMMAND_CODE, "DONOTUSE_createSchema");;
+ response = invokeJbpm(request);
- _logger.info("testFullProcessLifecycle() invoked");
- try
- {
- request = Helper.commandMessageTemplate();
- Helper.setStringValue(request, Constants.COMMAND_CODE, "DONOTUSE_createSchema");;
- response = invokeJbpm(request);
-
- opCode = Constants.OpCode.DeployProcessDefinition;
- request = Helper.commandMessageTemplate();
- Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
- String xml = getProcessDefinitionXml("process_01.xml");
- Helper.setStringValue(request, Constants.PROCESS_DEFINITION_XML, xml);
-
- response = invokeJbpm(request);
-
- _logger.info("Invoked : "+opCode.toString());
- _logger.info("Return code = "+Helper.getStringValue(response,Constants.RETURN_CODE));
- excJbpm = (Exception)Helper.getObjectValue(response,Constants.EXCEPTION);
- if (null==excJbpm)
- {
- _logger.info("PrcDef name = "+Helper.getObjectValue(response,Constants.PROCESS_DEFINITION_NAME));
- _logger.info("PrcDef vers = "+Helper.getObjectValue(response,Constants.PROCESS_DEFINITION_VERSION));
- }
- else
- _logger.error("Problems in jbpm.CommandInterpreter",excJbpm);
- _logger.info("_______________________________________________________________________");
-
- assertTrue(Constants.RETCODE_OK.equals(Helper.getObjectValue(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("Invoked : "+opCode.toString());
- _logger.info("Return code = "+Helper.getStringValue(response,Constants.RETURN_CODE));
- excJbpm = (Exception)Helper.getObjectValue(response,Constants.EXCEPTION);
- if (null==excJbpm)
- {
- instanceId = Helper.getLongValue(response,Constants.PROCESS_INSTANCE_ID);
- tokenId = Helper.getLongValue(response,Constants.TOKEN_ID);
- _logger.info("Process Id = "+instanceId);
- _logger.info("Token Id = "+tokenId);
- }
- else
- _logger.error("Problems in jbpm.CommandInterpreter",excJbpm);
- _logger.info("_______________________________________________________________________");
-
- assertTrue(Constants.RETCODE_OK.equals(Helper.getObjectValue(response, Constants.RETURN_CODE)));
-
- 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);
- signalToken = ! signalToken;
-
- response = invokeJbpm(request);
-
- if (null!=response)
+ opCode = Constants.OpCode.DeployProcessDefinition;
+ request = Helper.commandMessageTemplate();
+ Helper.setStringValue(request, Constants.COMMAND_CODE, opCode);
+ Helper.setStringValue(request, Constants.PROCESS_DEFINITION_XML
+ , JbpmTestUtil.stringFromFile("process_01.xml"));
+
+ response = invokeJbpm(request);
+ _logger.info(JbpmTestUtil.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(JbpmTestUtil.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;)
{
- _logger.info("Invoked : "+opCode.toString());
- _logger.info("Return code = "+Helper.getStringValue(response,Constants.RETURN_CODE));
- excJbpm = (Exception)Helper.getObjectValue(response,Constants.EXCEPTION);
- if (null==excJbpm)
- {
- instanceId = Helper.getLongValue(response,Constants.PROCESS_INSTANCE_ID);
- tokenId = Helper.getLongValue(response,Constants.TOKEN_ID);
- Token token = (Token)Helper.getObjectValue(response, Constants.JBPM_RETURN_OBJECT);
- boolean hasEnded = token.hasEnded();
- _logger.info("Has ended = "+ hasEnded);
- _logger.info("Current State = "+token.getNode().getName());
-
- continueLooping = ! hasEnded;
- }
+ 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(JbpmTestUtil.dumpResponse(response, opCode));
else
- _logger.error("Problems in jbpm.CommandInterpreter",excJbpm);
+ _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);
}
- else
- _logger.info("Response was not received");
- _logger.info("_______________________________________________________________________");
-
- assertTrue(Constants.RETCODE_OK.equals(Helper.getObjectValue(response, Constants.RETURN_CODE)));
- }
+
+ }
+ catch (Exception _ex)
+ {
+ _ex.printStackTrace();
+ assertTrue(false);
+ }
- }
- catch (Exception _ex)
- {
- _ex.printStackTrace();
- assertTrue(false);
- }
-
}
/**
More information about the jboss-svn-commits
mailing list