This is an automated email from the ASF dual-hosted git repository.
iuliana pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/brooklyn-server.git
The following commit(s) were added to refs/heads/master by this push:
new dd55e7b Extracted an if statement into a protected method so I can
call it from subclass
dd55e7b is described below
commit dd55e7b89ee8b9f66115903826987dcf92bd46b1
Author: iuliana <[email protected]>
AuthorDate: Tue Apr 6 12:29:31 2021 +0100
Extracted an if statement into a protected method so I can call it from
subclass
---
.../java/org/apache/brooklyn/entity/group/DynamicClusterImpl.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/core/src/main/java/org/apache/brooklyn/entity/group/DynamicClusterImpl.java
b/core/src/main/java/org/apache/brooklyn/entity/group/DynamicClusterImpl.java
index 9b8b00a..7e6b96f 100644
---
a/core/src/main/java/org/apache/brooklyn/entity/group/DynamicClusterImpl.java
+++
b/core/src/main/java/org/apache/brooklyn/entity/group/DynamicClusterImpl.java
@@ -587,10 +587,14 @@ public class DynamicClusterImpl extends AbstractGroupImpl
implements DynamicClus
ServiceStateLogic.setExpectedState(this, Lifecycle.ON_FIRE);
throw Exceptions.propagate(e);
} finally {
- if (clusterOneAndAllMembersUp != null)
clusterOneAndAllMembersUp.stop();
+ stopClusterAndMembersFeed();
}
}
+ protected void stopClusterAndMembersFeed(){
+ if (clusterOneAndAllMembersUp != null)
clusterOneAndAllMembersUp.stop();
+ }
+
@Override
public void restart() {
String mode = getConfig(RESTART_MODE);