camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r761895 - /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/TransactedJmsRouteTest.java
Date Sat, 04 Apr 2009 10:46:34 GMT
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) {



Mime
View raw message