[jboss-svn-commits] JBL Code SVN: r10984 - labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test.

[jboss-svn-commits at lists.jboss.org]

Author: estebanschifman
Date: 2007-04-15 18:34:21 -0400 (Sun, 15 Apr 2007)
New Revision: 10984

Modified:
   labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java
Log:
Use modified Invoker 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-15 22:32:49 UTC (rev 10983)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java	2007-04-15 22:34:21 UTC (rev 10984)
@@ -27,13 +27,10 @@
 import java.io.InputStream;
 import java.net.URISyntaxException;
 import java.util.Collection;
-import java.util.UUID;
 
 import org.apache.log4j.Logger;
-import org.jboss.soa.esb.addressing.Call;
 import org.jboss.soa.esb.addressing.EPR;
 import org.jboss.soa.esb.addressing.MalformedEPRException;
-import org.jboss.soa.esb.addressing.eprs.JMSEpr;
 import org.jboss.soa.esb.common.Environment;
 import org.jboss.soa.esb.common.ModulePropertyManager;
 import org.jboss.soa.esb.couriers.CourierException;
@@ -42,6 +39,7 @@
 import org.jboss.soa.esb.listeners.message.Invoker;
 import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.services.jbpm.util.CommandVehicle;
+import org.jboss.soa.esb.services.registry.RegistryException;
 
 import com.arjuna.common.util.propertyservice.PropertyManager;
 
@@ -69,26 +67,10 @@
 	
 	private Message invokeJbpm(CommandVehicle command)
 		throws CourierTimeoutException, CourierException
-		, MalformedEPRException, URISyntaxException
+		, MalformedEPRException, URISyntaxException, RegistryException
 	{
-		Message outgoing = command.toCommandMessage();
-		Call call	= outgoing.getHeader().getCall();
-		call.setTo(_jbpmEpr);
-
-		// The following code to avoid the need of a queue with the "_reply" suffix
-		if (_jbpmEpr instanceof JMSEpr)
-		{
-			JMSEpr epr = (JMSEpr)_jbpmEpr;
-			call.setReplyTo(new JMSEpr
-				(	epr.getDestinationType()
-					,epr.getDestinationName()
-					,epr.getConnectionFactory()
-					,epr.getJndiEnvironment()
-					,"replyUID='"+UUID.randomUUID().toString()+"'")
-				 );
-		}
-
-		return Invoker.invokeAndAwaitResponse(outgoing, 15000);
+	   return Invoker.invokeAndAwaitResponse
+	   		(command, "categoryJbpmService","nameJbpmService" , 15000);
 	}
 	
 	public void run() throws Exception {