mirror of https://github.com/apache/activemq.git
Fix broke test.. A transaction manager is now required when transacted endpoints are configured.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577869 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
8032375531
commit
54d24ad3bf
|
@ -16,6 +16,7 @@
|
|||
*/
|
||||
package org.apache.activemq.camel.component;
|
||||
|
||||
import org.springframework.jms.connection.JmsTransactionManager;
|
||||
import org.apache.camel.CamelContext;
|
||||
import org.apache.camel.ContextTestSupport;
|
||||
import org.apache.camel.builder.RouteBuilder;
|
||||
|
@ -69,11 +70,12 @@ public class ActiveMQRouteTest extends ContextTestSupport {
|
|||
from("activemq:queue:test.b").to("mock:result");
|
||||
|
||||
JmsEndpoint endpoint1 = (JmsEndpoint) endpoint("activemq:topic:quote.IONA");
|
||||
endpoint1.getConfiguration().setTransactionManager(new JmsTransactionManager());
|
||||
endpoint1.getConfiguration().setTransacted(true);
|
||||
from(endpoint1).to("mock:transactedClient");
|
||||
|
||||
JmsEndpoint endpoint2 = (JmsEndpoint) endpoint("activemq:topic:quote.IONA");
|
||||
endpoint1.getConfiguration().setTransacted(true);
|
||||
endpoint2.getConfiguration().setTransacted(false);
|
||||
from(endpoint2).to("mock:nonTrasnactedClient");
|
||||
}
|
||||
};
|
||||
|
|
Loading…
Reference in New Issue