You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/04/04 12:46:34 UTC
svn commit: r761895 -
/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java
Author: davsclaus
Date: Sat Apr 4 10:46:34 2009
New Revision: 761895
URL: http://svn.apache.org/viewvc?rev=761895&view=rev
Log:
CAMEL-1511: Preparing for TransactionErrorHandler improvements
Modified:
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java
Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java?rev=761895&r1=761894&r2=761895&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java Sat Apr 4 10:46:34 2009
@@ -30,6 +30,7 @@
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.processor.DelegateProcessor;
import org.apache.camel.spi.Policy;
+import org.apache.camel.spi.RouteContext;
import org.apache.camel.spring.SpringCamelContext;
import org.apache.camel.spring.SpringRouteBuilder;
import org.apache.camel.spring.spi.SpringTransactionPolicy;
@@ -66,7 +67,7 @@
SpringTransactionPolicy requirenew = new SpringTransactionPolicy(bean(TransactionTemplate.class, "PROPAGATION_REQUIRES_NEW"));
Policy rollback = new Policy() {
- public Processor wrap(Processor processor) {
+ public Processor wrap(RouteContext routeContext, Processor processor) {
return new DelegateProcessor(processor) {
@Override
public void process(Exchange exchange) throws Exception {
@@ -83,7 +84,7 @@
};
Policy catchRollback = new Policy() {
- public Processor wrap(Processor processor) {
+ public Processor wrap(RouteContext routeContext, Processor processor) {
return new DelegateProcessor(processor) {
@Override
public void process(Exchange exchange) {