You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2015/08/20 14:39:49 UTC
[11/16] incubator-brooklyn git commit: Adds TaskPredicates
Adds TaskPredicates
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/3385e7b3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/3385e7b3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/3385e7b3
Branch: refs/heads/master
Commit: 3385e7b3edebc05a6eab5229d4208226790b520f
Parents: f4533ed
Author: Aled Sage <al...@gmail.com>
Authored: Thu Aug 20 12:33:20 2015 +0100
Committer: Aled Sage <al...@gmail.com>
Committed: Thu Aug 20 12:34:20 2015 +0100
----------------------------------------------------------------------
.../brooklyn/util/core/task/TaskPredicates.java | 55 ++++++++++++++++++++
.../util/core/task/TaskPredicatesTest.java | 45 ++++++++++++++++
2 files changed, 100 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/3385e7b3/core/src/main/java/org/apache/brooklyn/util/core/task/TaskPredicates.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/brooklyn/util/core/task/TaskPredicates.java b/core/src/main/java/org/apache/brooklyn/util/core/task/TaskPredicates.java
new file mode 100644
index 0000000..3e42760
--- /dev/null
+++ b/core/src/main/java/org/apache/brooklyn/util/core/task/TaskPredicates.java
@@ -0,0 +1,55 @@
+/*
+ * 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.util.core.task;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import org.apache.brooklyn.api.mgmt.Task;
+
+import com.google.common.base.Predicate;
+import com.google.common.base.Predicates;
+
+public class TaskPredicates {
+
+ public static Predicate<Task<?>> displayNameMatches(Predicate<? super String> matcher) {
+ return new DisplayNameMatches(matcher);
+ }
+
+ public static Predicate<Task<?>> displayNameEqualTo(String name) {
+ return displayNameMatches(Predicates.equalTo(name));
+ }
+
+ private static class DisplayNameMatches implements Predicate<Task<?>> {
+ private final Predicate<? super String> matcher;
+
+ public DisplayNameMatches(Predicate<? super String> matcher) {
+ this.matcher = checkNotNull(matcher, "matcher");
+ }
+
+ @Override
+ public boolean apply(Task<?> input) {
+ return input != null && matcher.apply(input.getDisplayName());
+ }
+
+ @Override
+ public String toString() {
+ return "displayNameMatches("+matcher+")";
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/3385e7b3/core/src/test/java/org/apache/brooklyn/util/core/task/TaskPredicatesTest.java
----------------------------------------------------------------------
diff --git a/core/src/test/java/org/apache/brooklyn/util/core/task/TaskPredicatesTest.java b/core/src/test/java/org/apache/brooklyn/util/core/task/TaskPredicatesTest.java
new file mode 100644
index 0000000..d87dbb5
--- /dev/null
+++ b/core/src/test/java/org/apache/brooklyn/util/core/task/TaskPredicatesTest.java
@@ -0,0 +1,45 @@
+package org.apache.brooklyn.util.core.task;
+
+import static org.testng.Assert.assertFalse;
+import static org.testng.Assert.assertTrue;
+
+import org.apache.brooklyn.api.mgmt.ExecutionManager;
+import org.apache.brooklyn.api.mgmt.Task;
+import org.apache.brooklyn.core.test.BrooklynAppUnitTestSupport;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+import com.google.common.base.Predicates;
+import com.google.common.util.concurrent.Callables;
+
+public class TaskPredicatesTest extends BrooklynAppUnitTestSupport {
+
+ private ExecutionManager execManager;
+
+ @BeforeMethod(alwaysRun=true)
+ @Override
+ public void setUp() throws Exception {
+ super.setUp();
+ execManager = mgmt.getExecutionManager();
+ }
+
+ @Test
+ public void testDisplayNameEqualTo() throws Exception {
+ Task<Object> task = execManager.submit(TaskBuilder.builder()
+ .body(Callables.<Object>returning("val"))
+ .displayName("myname")
+ .build());
+ assertTrue(TaskPredicates.displayNameEqualTo("myname").apply(task));
+ assertFalse(TaskPredicates.displayNameEqualTo("wrong").apply(task));
+ }
+
+ @Test
+ public void testDisplayNameMatches() throws Exception {
+ Task<Object> task = execManager.submit(TaskBuilder.builder()
+ .body(Callables.<Object>returning("val"))
+ .displayName("myname")
+ .build());
+ assertTrue(TaskPredicates.displayNameMatches(Predicates.equalTo("myname")).apply(task));
+ assertFalse(TaskPredicates.displayNameMatches(Predicates.equalTo("wrong")).apply(task));
+ }
+}