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 2013/04/10 08:16:34 UTC
svn commit: r1466341 - in /camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm: DirectVmConsumerNotAvailableException.java DirectVmProducer.java

Author: davsclaus
Date: Wed Apr 10 06:16:33 2013
New Revision: 1466341

URL: http://svn.apache.org/r1466341
Log:
CAMEL-6105: The direct-vm component should also thrown special exception if no consumers avail, just like direct does.

Added:
    camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java
      - copied, changed from r1466035, camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java
Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java

Copied: camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java (from r1466035, camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java)
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java?p2=camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java&p1=camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java&r1=1466035&r2=1466341&rev=1466341&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java Wed Apr 10 06:16:33 2013
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.camel.component.direct;
+package org.apache.camel.component.directvm;
 
 import org.apache.camel.CamelExchangeException;
 import org.apache.camel.Exchange;
@@ -24,9 +24,9 @@ import org.apache.camel.Exchange;
  *
  * @version
  */
-public class DirectConsumerNotAvailableException extends CamelExchangeException {
+public class DirectVmConsumerNotAvailableException extends CamelExchangeException {
 
-    public DirectConsumerNotAvailableException(String message, Exchange exchange) {
+    public DirectVmConsumerNotAvailableException(String message, Exchange exchange) {
         super(message, exchange);
     }
 }
\ No newline at end of file

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java?rev=1466341&r1=1466340&r2=1466341&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java Wed Apr 10 06:16:33 2013
@@ -45,7 +45,7 @@ public class DirectVmProducer extends De
         DirectVmConsumer consumer = endpoint.getComponent().getConsumer(endpoint);
         if (consumer == null) {
             LOG.warn("No consumers available on endpoint: " + endpoint + " to process: " + exchange);
-            throw new CamelExchangeException("No consumers available on endpoint: " + endpoint, exchange);
+            throw new DirectVmConsumerNotAvailableException("No consumers available on endpoint: " + endpoint, exchange);
         } else {
             consumer.getProcessor().process(exchange);
         }
@@ -57,7 +57,7 @@ public class DirectVmProducer extends De
         DirectVmConsumer consumer = endpoint.getComponent().getConsumer(endpoint);
         if (consumer == null) {
             LOG.warn("No consumers available on endpoint: " + endpoint + " to process: " + exchange);
-            exchange.setException(new CamelExchangeException("No consumers available on endpoint: " + endpoint, exchange));
+            exchange.setException(new DirectVmConsumerNotAvailableException("No consumers available on endpoint: " + endpoint, exchange));
             callback.done(true);
             return true;
         } else {