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 2015/04/11 15:57:42 UTC
camel git commit: CAMEL-8617: In case vertx already stopped then
avoid ugly stacktrace.
Repository: camel
Updated Branches:
refs/heads/master 7e4b0b67d -> 1ea580dab
CAMEL-8617: In case vertx already stopped then avoid ugly stacktrace.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1ea580da
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1ea580da
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1ea580da
Branch: refs/heads/master
Commit: 1ea580dabc1dc9d1d28a3ed4a9535dc0b8d2ca39
Parents: 7e4b0b6
Author: Claus Ibsen <da...@apache.org>
Authored: Sat Apr 11 15:59:58 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sat Apr 11 15:59:58 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/vertx/VertxConsumer.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/1ea580da/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxConsumer.java b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxConsumer.java
index a805fb6..46d79a9 100644
--- a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxConsumer.java
+++ b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxConsumer.java
@@ -82,7 +82,13 @@ public class VertxConsumer extends DefaultConsumer {
LOG.debug("Unregistering EventBus handler on address {}", endpoint.getAddress());
}
- endpoint.getEventBus().unregisterHandler(endpoint.getAddress(), handler);
+ try {
+ endpoint.getEventBus().unregisterHandler(endpoint.getAddress(), handler);
+ } catch (IllegalStateException e) {
+ LOG.warn("EventBus already stopped on address {}", endpoint.getAddress());
+ // ignore if already stopped as vertx throws this exception if its already stopped etc.
+ // unfortunately it does not provide an nicer api to know its state
+ }
super.doStop();
}
}