camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r772500 - in /camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms: JmsComponent.java JmsEndpoint.java JmsExchange.java JmsProducer.java
Date Thu, 07 May 2009 04:51:17 GMT
Author: davsclaus
Date: Thu May  7 04:51:16 2009
New Revision: 772500

URL: http://svn.apache.org/viewvc?rev=772500&view=rev
Log:
CAMEL-1587: Fixed compilation error

Modified:
    camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
    camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
    camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsExchange.java
    camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java

Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java?rev=772500&r1=772499&r2=772500&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
(original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
Thu May  7 04:51:16 2009
@@ -309,7 +309,7 @@
 
     public synchronized Requestor getRequestor() throws Exception {
         if (requestor == null) {
-            requestor = new Requestor(getConfiguration(), getExecutorService());
+            requestor = new Requestor(getConfiguration(), getScheduledExecutorService());
             requestor.start();
         }
         return requestor;

Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java?rev=772500&r1=772499&r2=772500&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
(original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
Thu May  7 04:51:16 2009
@@ -290,7 +290,7 @@
 
     public synchronized Requestor getRequestor() throws Exception {
         if (requestor == null) {
-            requestor = new Requestor(getConfiguration(), getExecutorService());
+            requestor = new Requestor(getConfiguration(), getScheduledExecutorService());
             requestor.start();
         }
         return requestor;

Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsExchange.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsExchange.java?rev=772500&r1=772499&r2=772500&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsExchange.java
(original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsExchange.java
Thu May  7 04:51:16 2009
@@ -73,6 +73,11 @@
         return (JmsMessage) super.getFault();
     }
 
+    @Override
+    public JmsMessage getFault(boolean lazyCreate) {
+        return (JmsMessage) super.getFault(lazyCreate);
+    }
+
     public JmsBinding getBinding() {
         return binding;
     }

Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java?rev=772500&r1=772499&r2=772500&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
(original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsProducer.java
Thu May  7 04:51:16 2009
@@ -100,11 +100,11 @@
                 try {
                     JmsConfiguration c = endpoint.getConfiguration();
                     if (c.getReplyTo() != null) {
-                        requestor = new PersistentReplyToRequestor(endpoint.getConfiguration(),
endpoint.getExecutorService());
+                        requestor = new PersistentReplyToRequestor(endpoint.getConfiguration(),
endpoint.getScheduledExecutorService());
                         requestor.start();
                     } else {
                         if (affinity == RequestorAffinity.PER_PRODUCER) {
-                            requestor = new Requestor(endpoint.getConfiguration(), endpoint.getExecutorService());
+                            requestor = new Requestor(endpoint.getConfiguration(), endpoint.getScheduledExecutorService());
                             requestor.start();
                         } else if (affinity == RequestorAffinity.PER_ENDPOINT) {
                             requestor = endpoint.getRequestor();



Mime
View raw message