brooklyn-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aleds...@apache.org
Subject [1/2] brooklyn-server git commit: BROOKLYN-396: add Sam’s DynamicCluster rebind test
Date Sun, 20 Nov 2016 20:25:25 GMT
Repository: brooklyn-server
Updated Branches:
  refs/heads/master bf280f124 -> 24fa6fe62


BROOKLYN-396: add Sam’s DynamicCluster rebind test

Project: http://git-wip-us.apache.org/repos/asf/brooklyn-server/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-server/commit/8485f8a6
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-server/tree/8485f8a6
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-server/diff/8485f8a6

Branch: refs/heads/master
Commit: 8485f8a6cd9efd7ed287f09c99be4f02398e223b
Parents: bf280f1
Author: Aled Sage <aled.sage@gmail.com>
Authored: Sat Nov 19 17:45:28 2016 +0000
Committer: Aled Sage <aled.sage@gmail.com>
Committed: Sun Nov 20 20:23:42 2016 +0000

----------------------------------------------------------------------
 .../entity/group/DynamicClusterRebindTest.java  | 52 ++++++++++++++++++++
 1 file changed, 52 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/brooklyn-server/blob/8485f8a6/software/base/src/test/java/org/apache/brooklyn/entity/group/DynamicClusterRebindTest.java
----------------------------------------------------------------------
diff --git a/software/base/src/test/java/org/apache/brooklyn/entity/group/DynamicClusterRebindTest.java
b/software/base/src/test/java/org/apache/brooklyn/entity/group/DynamicClusterRebindTest.java
new file mode 100644
index 0000000..c9b361e
--- /dev/null
+++ b/software/base/src/test/java/org/apache/brooklyn/entity/group/DynamicClusterRebindTest.java
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.brooklyn.entity.group;
+
+import org.apache.brooklyn.api.entity.EntitySpec;
+import org.apache.brooklyn.core.entity.Attributes;
+import org.apache.brooklyn.core.entity.Entities;
+import org.apache.brooklyn.core.entity.EntityAsserts;
+import org.apache.brooklyn.core.entity.lifecycle.Lifecycle;
+import org.apache.brooklyn.core.mgmt.rebind.RebindOptions;
+import org.apache.brooklyn.core.mgmt.rebind.RebindTestFixtureWithApp;
+import org.apache.brooklyn.entity.software.base.EmptySoftwareProcess;
+import org.testng.annotations.Test;
+
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.Iterables;
+
+public class DynamicClusterRebindTest extends RebindTestFixtureWithApp {
+
+    // See https://issues.apache.org/jira/browse/BROOKLYN-396
+    @Test(groups = "Integration")
+    public void testResizeAfterRebind() throws Exception {
+        DynamicCluster cluster = app().createAndManageChild(EntitySpec.create(DynamicCluster.class)
+                .configure(DynamicCluster.INITIAL_SIZE, 3)
+                .configure(DynamicCluster.MEMBER_SPEC, EntitySpec.create(EmptySoftwareProcess.class)));
+        app().start(ImmutableList.of(app().newLocalhostProvisioningLocation()));
+        EntityAsserts.assertAttributeEquals(cluster, DynamicCluster.GROUP_SIZE, 3);
+
+        rebind(RebindOptions.create().terminateOrigManagementContext(true));
+
+        cluster = Iterables.getOnlyElement(Entities.descendantsAndSelf(newApp, DynamicCluster.class));
+        cluster.resize(5);
+        EntityAsserts.assertAttributeEquals(cluster, DynamicCluster.GROUP_SIZE, 5);
+        EntityAsserts.assertAttributeEquals(cluster, Attributes.SERVICE_STATE_ACTUAL, Lifecycle.RUNNING);
+    }
+}


Mime
View raw message