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 2010/03/22 08:44:17 UTC
svn commit: r925987 - in
/camel/trunk/camel-core/src/main/java/org/apache/camel: AsyncProcessor.java
impl/DefaultShutdownStrategy.java
Author: davsclaus
Date: Mon Mar 22 07:44:17 2010
New Revision: 925987
URL: http://svn.apache.org/viewvc?rev=925987&view=rev
Log:
Logging cause exception at WARN if shutdown route failed. Fixed spelling.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/AsyncProcessor.java
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultShutdownStrategy.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/AsyncProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/AsyncProcessor.java?rev=925987&r1=925986&r2=925987&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/AsyncProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/AsyncProcessor.java Mon Mar 22 07:44:17 2010
@@ -20,7 +20,7 @@ package org.apache.camel;
* An <b>asynchronous</b> processor which can process an {@link Exchange} in an asynchronous fashion
* and signal completion by invoking the {@link AsyncCallback}.
* <p/>
- * For example {@link Producer} can implmenet this interface to support real asynchronous non blocking
+ * For example {@link Producer} can implement this interface to support real asynchronous non blocking
* when using the {@link org.apache.camel.processor.SendAsyncProcessor}.
*
* @version $Revision$
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultShutdownStrategy.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultShutdownStrategy.java?rev=925987&r1=925986&r2=925987&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultShutdownStrategy.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultShutdownStrategy.java Mon Mar 22 07:44:17 2010
@@ -103,7 +103,7 @@ public class DefaultShutdownStrategy ext
// force the routes to shutdown now
shutdownRoutesNow(routes);
} else {
- LOG.warn("Timeout occurred. Will ignore shutting down the remainder route input consumers.");
+ LOG.warn("Timeout occurred. Will ignore shutting down the remainder routes.");
}
} catch (ExecutionException e) {
// unwrap execution exception
@@ -196,8 +196,8 @@ public class DefaultShutdownStrategy ext
// allow us to do custom work before delegating to service helper
try {
ServiceHelper.stopService(consumer);
- } catch (Exception e) {
- LOG.warn("Error occurred while shutting down route: " + consumer + ". This exception will be ignored.");
+ } catch (Throwable e) {
+ LOG.warn("Error occurred while shutting down route: " + consumer + ". This exception will be ignored.", e);
// fire event
EventHelper.notifyServiceStopFailure(consumer.getEndpoint().getCamelContext(), consumer, e);
}
@@ -220,8 +220,8 @@ public class DefaultShutdownStrategy ext
try {
service.suspend();
- } catch (Exception e) {
- LOG.warn("Error occurred while suspending route: " + consumer + ". This exception will be ignored.");
+ } catch (Throwable e) {
+ LOG.warn("Error occurred while suspending route: " + consumer + ". This exception will be ignored.", e);
// fire event
EventHelper.notifyServiceStopFailure(consumer.getEndpoint().getCamelContext(), consumer, e);
}