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/11/21 21:31:16 UTC
[6/6] git commit: CAMEL-6994: Load balancer should only clear
processors on shutdown. Thanks to Metatech for the patch.
CAMEL-6994: Load balancer should only clear processors on shutdown. Thanks to Metatech for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d669f920
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d669f920
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d669f920
Branch: refs/heads/camel-2.11.x
Commit: d669f920b13e39ff8468d965424b0c75e9ec8c5d
Parents: 5695422
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Nov 21 21:30:53 2013 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Nov 21 21:32:49 2013 +0100
----------------------------------------------------------------------
.../camel/processor/loadbalancer/LoadBalancerSupport.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/d669f920/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/LoadBalancerSupport.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/LoadBalancerSupport.java b/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/LoadBalancerSupport.java
index 1957ae3..238457f 100644
--- a/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/LoadBalancerSupport.java
+++ b/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/LoadBalancerSupport.java
@@ -73,6 +73,11 @@ public abstract class LoadBalancerSupport extends ServiceSupport implements Load
protected void doStop() throws Exception {
ServiceHelper.stopServices(processors);
+ }
+
+ @Override
+ protected void doShutdown() throws Exception {
+ ServiceHelper.stopAndShutdownServices(processors);
for (Processor processor : processors) {
removeProcessor(processor);
}