You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2011/04/05 15:38:29 UTC
svn commit: r1089037 -
/activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/CamelRedeliveryTest.java
Author: gtully
Date: Tue Apr 5 13:38:29 2011
New Revision: 1089037
URL: http://svn.apache.org/viewvc?rev=1089037&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-2710 - use original destination from the message original for the test
Modified:
activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/CamelRedeliveryTest.java
Modified: activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/CamelRedeliveryTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/CamelRedeliveryTest.java?rev=1089037&r1=1089036&r2=1089037&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/CamelRedeliveryTest.java (original)
+++ activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/CamelRedeliveryTest.java Tue Apr 5 13:38:29 2011
@@ -92,9 +92,7 @@ public class CamelRedeliveryTest extends
@RecipientList @Handler
public String routeTo(ActiveMQMessage body) throws Exception {
- ActiveMQDestination originalDestination = new ActiveMQQueue("camelRedeliveryQ");
- // or pull value from the message; body.getOriginalDestination();
-
+ ActiveMQDestination originalDestination = body.getOriginalDestination();
return "activemq:" + originalDestination.getPhysicalName() + "?explicitQosEnabled=true&messageConverter=#messageConverter";
}
}