camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r772297 - in /camel/trunk: camel-core/src/main/java/org/apache/camel/impl/ camel-core/src/main/java/org/apache/camel/management/ camel-core/src/main/java/org/apache/camel/model/ camel-core/src/main/java/org/apache/camel/processor/ camel-cor...
Date Wed, 06 May 2009 15:10:53 GMT
Author: davsclaus
Date: Wed May  6 15:10:52 2009
New Revision: 772297

URL: http://svn.apache.org/viewvc?rev=772297&view=rev
Log:
CAMEL-1587: Using ExecutorServiceHelper for creating thread pools. Removed classes no longer
needed. Added camel 1.6.0 release to spring.schema files

Removed:
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Interceptor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ProceedProcessor.java
Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultInstrumentationAgent.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Resequencer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/FailOverLoadBalancer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/ExecutorServiceHelper.java
    camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java
    camel/trunk/camel-core/src/test/java/org/apache/camel/builder/RouteBuilderTest.java
    camel/trunk/components/camel-spring/src/main/resources/META-INF/spring.schemas

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java Wed May
 6 15:10:52 2009
@@ -20,8 +20,7 @@
 import java.util.Iterator;
 import java.util.Map;
 import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ExecutorService;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.Component;
@@ -32,6 +31,7 @@
 import org.apache.camel.util.ObjectHelper;
 import org.apache.camel.util.URISupport;
 import org.apache.camel.util.UnsafeUriCharactersEncoder;
+import org.apache.camel.util.concurrent.ExecutorServiceHelper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -46,7 +46,7 @@
 
     private static final int DEFAULT_THREADPOOL_SIZE = 5;
     private CamelContext camelContext;
-    private ScheduledExecutorService executorService;
+    private ExecutorService executorService;
 
     public DefaultComponent() {
     }
@@ -149,7 +149,7 @@
         this.camelContext = context;
     }
 
-    public ScheduledExecutorService getExecutorService() {
+    public ExecutorService getExecutorService() {
         if (executorService == null) {
             executorService = createExecutorService();
         }
@@ -163,16 +163,8 @@
     /**
      * A factory method to create a default thread pool and executor
      */
-    protected ScheduledExecutorService createExecutorService() {
-        return new ScheduledThreadPoolExecutor(DEFAULT_THREADPOOL_SIZE, new ThreadFactory()
{
-            int counter;
-
-            public synchronized Thread newThread(Runnable runnable) {
-                Thread thread = new Thread(runnable);
-                thread.setName("Thread: " + (++counter) + " " + DefaultComponent.this.toString());
-                return thread;
-            }
-        });
+    protected ExecutorService createExecutorService() {
+        return ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE, this.toString(),
true);
     }
 
     protected void doStart() throws Exception {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java Wed May
 6 15:10:52 2009
@@ -19,8 +19,8 @@
 import java.lang.reflect.ParameterizedType;
 import java.lang.reflect.Type;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.CamelContextAware;
@@ -30,6 +30,7 @@
 import org.apache.camel.ExchangePattern;
 import org.apache.camel.PollingConsumer;
 import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.concurrent.ExecutorServiceHelper;
 
 /**
  * A default endpoint useful for implementation inheritance
@@ -37,10 +38,12 @@
  * @version $Revision$
  */
 public abstract class DefaultEndpoint implements Endpoint, CamelContextAware {
+    private static final int DEFAULT_THREADPOOL_SIZE = 5;
+
     private String endpointUri;
     private CamelContext camelContext;
     private Component component;
-    private ScheduledExecutorService executorService;
+    private ExecutorService executorService;
     private ExchangePattern exchangePattern = ExchangePattern.InOnly;
 
     protected DefaultEndpoint(String endpointUri, Component component) {
@@ -101,7 +104,7 @@
         this.camelContext = camelContext;
     }
 
-    public synchronized ScheduledExecutorService getExecutorService() {
+    public synchronized ExecutorService getExecutorService() {
         if (executorService == null) {
             Component c = getComponent();
             if (c instanceof DefaultComponent) {
@@ -180,8 +183,8 @@
         this.exchangePattern = exchangePattern;
     }
 
-    protected ScheduledThreadPoolExecutor createExecutorService() {
-        return new ScheduledThreadPoolExecutor(10);
+    protected ExecutorService createExecutorService() {
+        return ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE, getEndpointUri(),
true);
     }
 
     public void configureProperties(Map options) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
Wed May  6 15:10:52 2009
@@ -22,7 +22,6 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Future;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
@@ -38,6 +37,7 @@
 import org.apache.camel.util.CamelContextHelper;
 import org.apache.camel.util.ExchangeHelper;
 import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.concurrent.ExecutorServiceHelper;
 
 /**
  * A client helper object (named like Spring's TransactionTemplate & JmsTemplate
@@ -47,6 +47,7 @@
  * @version $Revision$
  */
 public class DefaultProducerTemplate extends ServiceSupport implements ProducerTemplate {
+    private static final int DEFAULT_THREADPOOL_SIZE = 5;
     private final CamelContext context;
     private final ProducerCache producerCache = new ProducerCache();
     // TODO: why do we have endpoint cache as camel context also have endpoint cache?
@@ -57,7 +58,7 @@
 
     public DefaultProducerTemplate(CamelContext context) {
         this.context = context;
-        this.executor = new ScheduledThreadPoolExecutor(5);
+        this.executor = ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE,
"ProducerTemplate", true);
     }
 
     public DefaultProducerTemplate(CamelContext context, ExecutorService executor) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultRouteContext.java Wed
May  6 15:10:52 2009
@@ -23,7 +23,6 @@
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
-import org.apache.camel.Intercept;
 import org.apache.camel.NoSuchEndpointException;
 import org.apache.camel.Processor;
 import org.apache.camel.Route;
@@ -31,9 +30,7 @@
 import org.apache.camel.model.ProcessorDefinition;
 import org.apache.camel.model.RouteDefinition;
 import org.apache.camel.model.dataformat.DataFormatDefinition;
-import org.apache.camel.processor.Interceptor;
 import org.apache.camel.processor.Pipeline;
-import org.apache.camel.processor.ProceedProcessor;
 import org.apache.camel.processor.UnitOfWorkProcessor;
 import org.apache.camel.spi.InterceptStrategy;
 import org.apache.camel.spi.RouteContext;
@@ -49,7 +46,6 @@
     private final Collection<Route> routes;
     private Endpoint endpoint;
     private final List<Processor> eventDrivenProcessors = new ArrayList<Processor>();
-    private Interceptor lastInterceptor;
     private CamelContext camelContext;
     private List<InterceptStrategy> interceptStrategies = new ArrayList<InterceptStrategy>();
     private boolean routeAdded;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
Wed May  6 15:10:52 2009
@@ -19,10 +19,12 @@
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.ExecutorService;
 
 import org.apache.camel.Endpoint;
 import org.apache.camel.Processor;
 import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.concurrent.ExecutorServiceHelper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -45,7 +47,18 @@
     private boolean useFixedDelay;
 
     public ScheduledPollConsumer(DefaultEndpoint endpoint, Processor processor) {
-        this(endpoint, processor, endpoint.getExecutorService());
+        super(endpoint, processor);
+
+        ScheduledExecutorService scheduled;
+        ExecutorService service = endpoint.getExecutorService();
+        if (service instanceof ScheduledExecutorService) {
+            scheduled = (ScheduledExecutorService) service;
+        } else {
+            scheduled = ExecutorServiceHelper.newScheduledThreadPool(5, getEndpoint().getEndpointUri(),
true);
+        }
+
+        this.executor = scheduled;
+        ObjectHelper.notNull(executor, "executor");
     }
 
     public ScheduledPollConsumer(Endpoint endpoint, Processor processor, ScheduledExecutorService
executor) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultInstrumentationAgent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultInstrumentationAgent.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultInstrumentationAgent.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultInstrumentationAgent.java
Wed May  6 15:10:52 2009
@@ -26,8 +26,6 @@
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ThreadFactory;
 import javax.management.JMException;
 import javax.management.MBeanServer;
 import javax.management.MBeanServerFactory;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java Wed
May  6 15:10:52 2009
@@ -23,7 +23,6 @@
 import java.util.Comparator;
 import java.util.LinkedList;
 import java.util.List;
-import java.util.concurrent.Executor;
 
 import javax.xml.bind.annotation.XmlAccessType;
 import javax.xml.bind.annotation.XmlAccessorType;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Resequencer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Resequencer.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Resequencer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Resequencer.java Wed May
 6 15:10:52 2009
@@ -34,6 +34,7 @@
  * @version $Revision$
  */
 public class Resequencer extends BatchProcessor {
+
     public Resequencer(Processor processor, Expression expression) {
         this(processor, createSet(expression));
     }

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/SendProcessor.java Wed
May  6 15:10:52 2009
@@ -77,6 +77,7 @@
 
     protected void doStop() throws Exception {
         ServiceHelper.stopService(this.producer);
+        this.producer = null;
     }
 
     protected Exchange configureExchange(Exchange exchange) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
Wed May  6 15:10:52 2009
@@ -18,8 +18,6 @@
 
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.ThreadFactory;
 
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
@@ -28,6 +26,7 @@
 import org.apache.camel.Processor;
 import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.concurrent.ExecutorServiceHelper;
 
 /**
  * Processor for wire tapping exchanges to an endpoint destination.
@@ -36,7 +35,6 @@
  */
 public class WireTapProcessor extends SendProcessor {
 
-    private int defaultThreadPoolSize = 5;
     private ExecutorService executorService;
 
     // expression or processor used for populating a new exchange to send
@@ -144,15 +142,7 @@
     }
 
     private ExecutorService createExecutorService() {
-        return new ScheduledThreadPoolExecutor(defaultThreadPoolSize, new ThreadFactory()
{
-            int counter;
-
-            public synchronized Thread newThread(Runnable runnable) {
-                Thread thread = new Thread(runnable);
-                thread.setName("Thread: " + (++counter) + " " + WireTapProcessor.this.toString());
-                return thread;
-            }
-        });
+        return ExecutorServiceHelper.newScheduledThreadPool(5, this.toString(), true);
     }
 
     public void setExecutorService(ExecutorService executorService) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/FailOverLoadBalancer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/FailOverLoadBalancer.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/FailOverLoadBalancer.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/FailOverLoadBalancer.java
Wed May  6 15:10:52 2009
@@ -50,17 +50,6 @@
         return false;
     }
 
-    private void processExchange(Processor processor, Exchange exchange) {
-        if (processor == null) {
-            throw new IllegalStateException("No processors could be chosen to process " +
exchange);
-        }
-        try {
-            processor.process(exchange);
-        } catch (Exception e) {
-            exchange.setException(e);
-        }
-    }
-
     public void process(Exchange exchange) throws Exception {
         List<Processor> list = getProcessors();
         if (list.isEmpty()) {
@@ -81,28 +70,15 @@
         }
     }
 
-    protected void processExchange(final int index, final Exchange exchange) {
-        List<Processor> list = getProcessors();
-        if (list.isEmpty()) {
-            throw new IllegalStateException("No processors available to process " + exchange);
-        }
-
-        Processor processor = list.get(index);
+    private void processExchange(Processor processor, Exchange exchange) {
         if (processor == null) {
             throw new IllegalStateException("No processors could be chosen to process " +
exchange);
         }
-
         try {
             processor.process(exchange);
-        } catch (Exception ex) {
-            exchange.setException(ex);
-        }
-
-        if (isCheckedException(exchange) && index < getProcessors().size() - 1)
{
-            exchange.setException(null);
-            processExchange(index + 1, exchange);
+        } catch (Exception e) {
+            exchange.setException(e);
         }
-
     }
 
 }

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/ExecutorServiceHelper.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/ExecutorServiceHelper.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/ExecutorServiceHelper.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/ExecutorServiceHelper.java
Wed May  6 15:10:52 2009
@@ -19,6 +19,7 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ScheduledExecutorService;
 
 /**
  * Helper for {@link java.util.concurrent.ExecutorService} to construct executors using a
thread factory that
@@ -44,7 +45,7 @@
         return ++threadCounter;
     }
 
-    public static ExecutorService newScheduledThreadPool(final int poolSize, final String
name, final boolean daemon) {
+    public static ScheduledExecutorService newScheduledThreadPool(final int poolSize, final
String name, final boolean daemon) {
         return Executors.newScheduledThreadPool(poolSize, new ThreadFactory() {
             public Thread newThread(Runnable r) {
                 Thread answer = new Thread(r, getThreadName(name));

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/builder/BuilderWithScopesTest.java
Wed May  6 15:10:52 2009
@@ -103,7 +103,7 @@
         Producer producer = endpoint.createProducer();
         producer.process(exchange);
 
-        log.debug("Interceptor invocation order:" + order);
+        log.debug("Invocation order:" + order);
         assertEquals(expected, order);
     }
 

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/builder/RouteBuilderTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/builder/RouteBuilderTest.java?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/builder/RouteBuilderTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/builder/RouteBuilderTest.java Wed
May  6 15:10:52 2009
@@ -33,7 +33,6 @@
 import org.apache.camel.processor.DeadLetterChannel;
 import org.apache.camel.processor.DelegateProcessor;
 import org.apache.camel.processor.FilterProcessor;
-import org.apache.camel.processor.Interceptor;
 import org.apache.camel.processor.MulticastProcessor;
 import org.apache.camel.processor.Pipeline;
 import org.apache.camel.processor.RecipientList;
@@ -483,15 +482,6 @@
         }
     }
 
-    protected Processor unwrapInterceptor(Processor processor) {
-        if (processor instanceof Interceptor) {
-            Interceptor interceptor = (Interceptor) processor;
-            return interceptor.getProcessor();
-        } else {
-            return processor;
-        }
-    }
-    
     protected Processor unwrapDelegateProcessor(Processor processor) {
         if (processor instanceof DelegateProcessor) {
             DelegateProcessor delegate = (DelegateProcessor) processor;

Modified: camel/trunk/components/camel-spring/src/main/resources/META-INF/spring.schemas
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/main/resources/META-INF/spring.schemas?rev=772297&r1=772296&r2=772297&view=diff
==============================================================================
--- camel/trunk/components/camel-spring/src/main/resources/META-INF/spring.schemas (original)
+++ camel/trunk/components/camel-spring/src/main/resources/META-INF/spring.schemas Wed May
 6 15:10:52 2009
@@ -23,5 +23,6 @@
 http\://activemq.apache.org/camel/schema/spring/camel-spring-1.3.0.xsd=camel-spring.xsd
 http\://activemq.apache.org/camel/schema/spring/camel-spring-1.4.0.xsd=camel-spring.xsd
 http\://activemq.apache.org/camel/schema/spring/camel-spring-1.5.0.xsd=camel-spring.xsd
+http\://activemq.apache.org/camel/schema/spring/camel-spring-1.6.0.xsd=camel-spring.xsd
 
 http\://camel.apache.org/schema/spring/camel-spring-${pom.version}.xsd=camel-spring.xsd



Mime
View raw message