mirror of https://github.com/apache/activemq.git
https://issues.apache.org/jira/browse/AMQ-2710 - use original destination from the message original for the test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1089037 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
2327e3975b
commit
2f869e32d0
|
@ -92,9 +92,7 @@ public class CamelRedeliveryTest extends AbstractJUnit38SpringContextTests {
|
||||||
|
|
||||||
@RecipientList @Handler
|
@RecipientList @Handler
|
||||||
public String routeTo(ActiveMQMessage body) throws Exception {
|
public String routeTo(ActiveMQMessage body) throws Exception {
|
||||||
ActiveMQDestination originalDestination = new ActiveMQQueue("camelRedeliveryQ");
|
ActiveMQDestination originalDestination = body.getOriginalDestination();
|
||||||
// or pull value from the message; body.getOriginalDestination();
|
|
||||||
|
|
||||||
return "activemq:" + originalDestination.getPhysicalName() + "?explicitQosEnabled=true&messageConverter=#messageConverter";
|
return "activemq:" + originalDestination.getPhysicalName() + "?explicitQosEnabled=true&messageConverter=#messageConverter";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue