[jboss-svn-commits] JBL Code SVN: r10836 - in labs/jbossesb/trunk/product: core/rosetta/src/org/jboss/soa/esb/addressing/eprs and 3 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Mon Apr 9 09:12:54 EDT 2007
Author: estebanschifman
Date: 2007-04-09 09:12:54 -0400 (Mon, 09 Apr 2007)
New Revision: 10836
Added:
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFileReplyToEpr.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFtpReplyToEpr.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJdbcReplyToEpr.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java
Modified:
labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/Invoker.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/FileEpr.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JMSEpr.java
labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/CourierUtil.java
labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java
labs/jbossesb/trunk/product/samples/trailblazer/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java
Log:
Rename getTemporaryReplyToEpr to getDefaultReplyToEpr and change algorithm to obtain it
Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/Invoker.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/Invoker.java 2007-04-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/Invoker.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -130,7 +130,7 @@
if (waitForResponse)
{
if (null==call.getReplyTo())
- call.setReplyTo(CourierUtil.getTemporaryReplyToEpr(call.getTo()));
+ call.setReplyTo(CourierUtil.getDefaultReplyToEpr(call.getTo()));
receiver = CourierFactory.getPickupCourier(call.getReplyTo());
}
Added: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFileReplyToEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFileReplyToEpr.java (rev 0)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFileReplyToEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -0,0 +1,23 @@
+package org.jboss.soa.esb.addressing.eprs;
+
+import java.net.MalformedURLException;
+import java.net.URISyntaxException;
+import java.util.UUID;
+
+public class DefaultFileReplyToEpr extends FileEpr
+{
+
+ public DefaultFileReplyToEpr (FileEpr epr)
+ throws URISyntaxException, MalformedURLException
+ {
+ super(epr);
+ setPostSuffix(uniqueInputSuffix(epr));
+ }
+
+
+ static String uniqueInputSuffix(FileEpr epr)
+ throws URISyntaxException
+ {
+ return epr.getInputSuffix()+"."+FileEpr.DEFAULT_REPLY_TO_FILE_SUFFIX+UUID.randomUUID().toString();
+ }
+}
Property changes on: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFileReplyToEpr.java
___________________________________________________________________
Name: svn:eol-style
+ native
Added: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFtpReplyToEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFtpReplyToEpr.java (rev 0)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFtpReplyToEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -0,0 +1,15 @@
+package org.jboss.soa.esb.addressing.eprs;
+
+import java.net.URISyntaxException;
+
+public class DefaultFtpReplyToEpr extends FTPEpr
+{
+
+ public DefaultFtpReplyToEpr(FTPEpr epr)
+ throws URISyntaxException
+ {
+ super(epr);
+ setPostSuffix(DefaultFileReplyToEpr.uniqueInputSuffix(epr));
+ }
+
+}
Property changes on: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultFtpReplyToEpr.java
___________________________________________________________________
Name: svn:eol-style
+ native
Added: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJdbcReplyToEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJdbcReplyToEpr.java (rev 0)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJdbcReplyToEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -0,0 +1,20 @@
+package org.jboss.soa.esb.addressing.eprs;
+
+public class DefaultJdbcReplyToEpr extends JDBCEpr
+{
+
+ public DefaultJdbcReplyToEpr(JDBCEpr epr)
+ {
+ super(epr);
+ //TODO We need to add a 'selector' to the JDBCEpr also, so we can selectively pickup
+// if(toEpr instanceof JDBCEpr)
+// {
+// JDBCEpr fpr = (JDBCEpr)toEpr;
+// JDBCEpr temp = new JDBCEpr(fpr.getURL());
+//
+// String selector = getReplySelector();
+//
+// return temp;
+// }
+ }
+}
Property changes on: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJdbcReplyToEpr.java
___________________________________________________________________
Name: svn:eol-style
+ native
Added: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java (rev 0)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -0,0 +1,48 @@
+package org.jboss.soa.esb.addressing.eprs;
+
+import java.net.URISyntaxException;
+import java.util.UUID;
+
+import org.jboss.soa.esb.util.Util;
+
+public class DefaultJmsReplyToEpr extends JMSEpr{
+
+ public static final String REPLY_UUID_TAG = "jbossESBresponseUUID";
+
+ public DefaultJmsReplyToEpr(JMSEpr epr)
+ throws URISyntaxException
+ {
+ super( epr.getDestinationType()
+ ,replyDestinationName(epr)
+ ,epr.getConnectionFactory()
+ ,epr.getJndiEnvironment()
+ , replySelector(epr)
+ );
+ }
+ private static String replyDestinationName(JMSEpr toEpr)
+ throws URISyntaxException
+ {
+ return toEpr.getDestinationName()+JMSEpr.DEFAULT_REPLY_TO_DESTINATION_SUFFIX;
+ }
+
+ /**
+ * Unique reply message selector
+ *
+ * @return String - the generated unique reply selector.
+ */
+ private static String replySelector(JMSEpr epr)
+ throws URISyntaxException
+ {
+ StringBuilder sb = new StringBuilder();
+
+ String oldSelector = epr.getMessageSelector();
+ // If there was a message selector, use it
+ if (!Util.isNullString(oldSelector))
+ sb.append(oldSelector).append(",");
+ // And add a unique reply UUID
+ sb.append(REPLY_UUID_TAG)
+ .append("='").append(UUID.randomUUID().toString()).append("'");
+ return sb.toString();
+ }
+
+}
Property changes on: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java
___________________________________________________________________
Name: svn:eol-style
+ native
Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/FileEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/FileEpr.java 2007-04-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/FileEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -57,6 +57,8 @@
public static final String ERROR_DEL_TAG = "errorDelete";
public static final String URL_TAG = "URL";
+ public static final String DEFAULT_REPLY_TO_FILE_SUFFIX = "_reply";
+
public FileEpr (EPR epr)
{
copy(epr);
Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java 2007-04-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JDBCEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -61,6 +61,8 @@
public static final String POST_DEL_TAG = "postDelete";
public static final String ERROR_DEL_TAG = "errorDelete";
+ public static final String DEFAULT_REPLY_TO_TABLE_SUFFIX = "_reply_table";
+
public JDBCEpr (EPR epr)
{
copy(epr);
Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JMSEpr.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JMSEpr.java 2007-04-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/addressing/eprs/JMSEpr.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -76,6 +76,8 @@
public static final String QUEUE_TYPE = "queue";
public static final String TOPIC_TYPE = "topic";
+
+ public static final String DEFAULT_REPLY_TO_DESTINATION_SUFFIX = "_reply";
public JMSEpr(EPR epr)
{
Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/CourierUtil.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/CourierUtil.java 2007-04-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/CourierUtil.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -34,9 +34,7 @@
import java.io.StreamCorruptedException;
import java.net.MalformedURLException;
import java.net.URISyntaxException;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.UUID;
+import java.util.Properties;
import javax.xml.parsers.ParserConfigurationException;
@@ -46,6 +44,9 @@
import org.jboss.soa.esb.ConfigurationException;
import org.jboss.soa.esb.addressing.EPR;
import org.jboss.soa.esb.addressing.MalformedEPRException;
+import org.jboss.soa.esb.addressing.eprs.DefaultFileReplyToEpr;
+import org.jboss.soa.esb.addressing.eprs.DefaultFtpReplyToEpr;
+import org.jboss.soa.esb.addressing.eprs.DefaultJmsReplyToEpr;
import org.jboss.soa.esb.addressing.eprs.FTPEpr;
import org.jboss.soa.esb.addressing.eprs.FileEpr;
import org.jboss.soa.esb.addressing.eprs.JMSEpr;
@@ -56,115 +57,32 @@
public class CourierUtil
{
- public static final String CORRELATION_ID_TAG = "messageCorrelationId";
-
private CourierUtil() {}
- public static List<KeyValuePair> propertiesFromSelector(String selector)
- throws ConfigurationException
- {
- // No problem if selector is null - everything in queue will be returned
- List<KeyValuePair> oRet = new ArrayList<KeyValuePair>();
- if (!Util.isNullString(selector))
- {
- for (String sCurr : selector.split(","))
- {
- String[] sa = sCurr.split("=");
- if (sa.length != 2 || sa[1].charAt(0) != '\''
- || sa[1].charAt(-1 + sa[1].length()) != '\'')
- throw new ConfigurationException("Illegal message selector syntax <"
- + selector + ">");
- KeyValuePair oNew = new KeyValuePair(sa[0], sa[1].substring(0,
- -1 + sa[1].length()).substring(1));
- oRet.add(oNew);
- }
- }
- return oRet;
- }
-
/**
- * We will be listening the same queue, but with a 'temporary' message
- * selector based of a UUID.
- *
- * @param message
- * to which we ill add the CORRELATION_ID_TAG.
- * @return the generated unique reply selector.
- */
- public static String getReplySelector()
- {
- String uuId = UUID.randomUUID().toString();
- String uniqueReplySelector = new StringBuilder().append(
- CORRELATION_ID_TAG).append("='").append(uuId).append("'")
- .toString();
- return uniqueReplySelector;
- }
-
- /**
- * Build a temporary replyToEPR, based on the toEpr, to which we can reply
- * to.
- * <ul>
- * <li> for JMS we will use the toEpr, but change the message selector.
- * </ul>
- *
- * @param toEpr -
- * the toEPR which will be used a basis to generate the
- * replyToEPR.
- * @return replyToEPR - the EPR to which the pickup will be delivered.
+ * Obtain a default replyToEPR (based on the toEpr) to which we can reply to.
+ *
+ * @param toEpr - the toEPR which will be used a basis to generate the replyToEPR.
+ * @return EPR - the EPR to which the pickup will be delivered.
* @throws URISyntaxException,
* CourierException
*/
- public static EPR getTemporaryReplyToEpr(EPR toEpr)
+ public static EPR getDefaultReplyToEpr(EPR toEpr)
throws CourierException, MalformedEPRException
{
try
{
- if (null==toEpr)
- return null;
- if (toEpr instanceof JMSEpr)
- {
- JMSEpr jpr = (JMSEpr) toEpr;
- // Setting the replyTo to the queue we specific in the epr we are
- // going to call
- // The selectors will do the job.
- return new JMSEpr(jpr.getDestinationType(), jpr.getDestinationName(),
- jpr.getConnectionFactory(), jpr.getJndiEnvironment(), getReplySelector());
- }
- if(toEpr instanceof FileEpr)
- {
- FileEpr fpr = (FileEpr)toEpr;
- FileEpr temp = new FileEpr(fpr.getURL());
-
- String selector = getReplySelector();
- String suffix = fpr.getPostSuffix();
- if (null!=suffix)
- selector += suffix;
- temp.setPostSuffix(suffix);
-
- return temp;
- }
+ if (null==toEpr)
+ throw new IllegalArgumentException("toEpr must not be null");
+ if (toEpr instanceof JMSEpr)
+ return new DefaultJmsReplyToEpr((JMSEpr)toEpr);
+ // Check for FTPEpr first, as it extends FileEpr
if(toEpr instanceof FTPEpr)
- {
- FTPEpr fpr = (FTPEpr)toEpr;
- FTPEpr temp = new FTPEpr(fpr.getURL());
-
- String selector = getReplySelector();
- String suffix = fpr.getPostSuffix();
- if (null!=suffix)
- selector += suffix;
- temp.setPostSuffix(suffix);
-
- return temp;
- }
- //TODO We need to add a 'selector' to the JDBCEpr also, so we can selectively pickup
+ return new DefaultFtpReplyToEpr((FTPEpr)toEpr);
+ if(toEpr instanceof FileEpr)
+ return new DefaultFileReplyToEpr((FileEpr)toEpr);
// if(toEpr instanceof JDBCEpr)
-// {
-// JDBCEpr fpr = (JDBCEpr)toEpr;
-// JDBCEpr temp = new JDBCEpr(fpr.getURL());
-//
-// String selector = getReplySelector();
-//
-// return temp;
-// }
+// return new DefaultJdbcReplyToEpr((JDBCEpr)toEpr);
}
catch (MalformedURLException ex)
{
@@ -179,6 +97,34 @@
+toEpr.getClass().getSimpleName());
}
+ /**
+ * Obtain properties and values used in a JMS message selector
+ * @param selector: A valid JMS message selector
+ * @return: A Properties object containing the keys and values in the message selector
+ * @throws ConfigurationException
+ */
+ public static Properties propertiesFromSelector(String selector)
+ throws ConfigurationException
+ {
+ Properties oRet = new Properties();
+ if (!Util.isNullString(selector))
+ {
+ for (String sCurr : selector.split(","))
+ {
+ String[] sa = sCurr.split("=");
+ if (sa.length != 2 || sa[1].charAt(0) != '\''
+ || sa[1].charAt(-1 + sa[1].length()) != '\'')
+ throw new ConfigurationException("Illegal message selector syntax <"
+ + selector + "> list of comma separated key='value' expected");
+ KeyValuePair oNew = new KeyValuePair(sa[0], sa[1].substring(0,
+ -1 + sa[1].length()).substring(1));
+ oRet.put(oNew.getKey(), oNew.getValue());
+ }
+ }
+ return oRet;
+ }
+
+
public static File messageToLocalFile(File directory, Message message)
throws IOException, ParserConfigurationException
{
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-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/samples/quickstarts/jbpm_simple1/src/quickstart/jbpm_simple1/test/TestCommandMessages.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -4,10 +4,20 @@
import java.io.File;
import java.io.FileInputStream;
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;
+import org.jboss.soa.esb.couriers.CourierTimeoutException;
+import org.jboss.soa.esb.listeners.RegistryUtil;
import org.jboss.soa.esb.listeners.message.Invoker;
import org.jboss.soa.esb.message.Message;
import org.jboss.soa.esb.util.jbpm.CommandVehicle;
@@ -18,6 +28,8 @@
static Logger _logger = Logger.getLogger(TestCommandMessages.class);
+ EPR _jbpmEpr;
+
public static void main(String[] args) throws Exception
{
try
@@ -32,18 +44,49 @@
}
}
+ private Message invokeJbpm(CommandVehicle command)
+ throws CourierTimeoutException, CourierException
+ , MalformedEPRException, URISyntaxException
+ {
+ 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);
+ }
+
public void run() throws Exception {
String category = "categoryJbpmSimple1";
String name = "nameJbpmSimple1";
-
+
+ Collection<EPR> eprs = RegistryUtil.getEprs(category, name);
+ if (eprs.size()<1)
+ throw new Exception("No listeners serving <"+category+","+name+">");
+
+ // Use first EPR
+ _jbpmEpr = eprs.iterator().next();
+
Enum operation = null;
CommandVehicle command = null;
operation = CommandVehicle.Operation.deployProcessDefinition;
command = new CommandVehicle(operation);
command.setProcessDefinition(getProcessDefinitionXml("processdefinition.xml"));
- Message respMsg = Invoker.invokeAndAwaitResponse(command,category,name,15000);
+ Message respMsg = invokeJbpm(command);
CommandVehicle response = (null==respMsg) ? null : new CommandVehicle(respMsg);
if (null!=response)
{
@@ -66,7 +109,7 @@
operation = CommandVehicle.Operation.newProcessInstance;
command = new CommandVehicle(operation);
command.setProcessDefinitionName(response.getProcessDefinitionName());
- respMsg = Invoker.invokeAndAwaitResponse(command,category,name,15000);
+ respMsg = invokeJbpm(command);
response = (null==respMsg) ? null : new CommandVehicle(respMsg);
if (null!=response)
{
@@ -100,7 +143,7 @@
command = new CommandVehicle(operation);
command.setInstanceId(response.getInstanceId());
command.setTokenId(response.getTokenId());
- respMsg = Invoker.invokeAndAwaitResponse(command,category,name,15000);
+ respMsg = invokeJbpm(command);
response = (null==respMsg) ? null : new CommandVehicle(respMsg);
if (null!=response)
{
@@ -135,7 +178,7 @@
operation = CommandVehicle.Operation.hasInstanceEnded;
command = new CommandVehicle(operation);
command.setInstanceId(response.getInstanceId());
- respMsg = Invoker.invokeAndAwaitResponse(command,category,name,15000);
+ respMsg = invokeJbpm(command);
response = (null==respMsg) ? null : new CommandVehicle(respMsg);
if (null!=response)
{
Modified: labs/jbossesb/trunk/product/samples/trailblazer/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java 2007-04-08 20:54:34 UTC (rev 10835)
+++ labs/jbossesb/trunk/product/samples/trailblazer/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java 2007-04-09 13:12:54 UTC (rev 10836)
@@ -166,7 +166,7 @@
throw new ActionProcessingException("could not find a courier to deliver the message for the serrvice " +
"(category-name: " + serviceCategoryName +"-" + serviceCategoryName); }
- replyEPR = (JMSEpr)CourierUtil.getTemporaryReplyToEpr(toEPR);
+ replyEPR = (JMSEpr)CourierUtil.getDefaultReplyToEpr(toEPR);
message.getHeader().getCall().setReplyTo(replyEPR);
//send the message and get the response
More information about the jboss-svn-commits
mailing list