This is an automated email from the ASF dual-hosted git repository.

duncangrant 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 b719f22958 Makes WorkflowSensor public and extensible
     new 9550789cf7 Merge pull request #1379 from 
nakomis/workflow-sensor-visibility
b719f22958 is described below

commit b719f229586ecd7ce556368d0e3445227cdf135d
Author: Martin Harris <git...@nakomis.com>
AuthorDate: Wed Feb 15 13:41:57 2023 +0000

    Makes WorkflowSensor public and extensible
---
 .../java/org/apache/brooklyn/core/workflow/WorkflowSensor.java    | 8 ++++++--
 .../org/apache/brooklyn/util/core/xstream/XmlSerializerTest.java  | 2 --
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/core/src/main/java/org/apache/brooklyn/core/workflow/WorkflowSensor.java 
b/core/src/main/java/org/apache/brooklyn/core/workflow/WorkflowSensor.java
index 4f07479c34..c24195fa70 100644
--- a/core/src/main/java/org/apache/brooklyn/core/workflow/WorkflowSensor.java
+++ b/core/src/main/java/org/apache/brooklyn/core/workflow/WorkflowSensor.java
@@ -55,7 +55,7 @@ import java.util.concurrent.Callable;
  * Configurable {@link EntityInitializer} which adds a sensor feed running a 
given workflow.
  */
 @Beta
-public final class WorkflowSensor<T> extends AbstractAddTriggerableSensor<T> 
implements WorkflowCommonConfig {
+public class WorkflowSensor<T> extends AbstractAddTriggerableSensor<T> 
implements WorkflowCommonConfig {
 
     private static final Logger LOG = 
LoggerFactory.getLogger(WorkflowSensor.class);
 
@@ -142,7 +142,7 @@ public final class WorkflowSensor<T> extends 
AbstractAddTriggerableSensor<T> imp
         return s;
     }
 
-    static class WorkflowPollCallable implements Callable<Object> {
+    public static class WorkflowPollCallable implements Callable<Object> {
         private final String workflowCallableName;
         private BrooklynObject entityOrAdjunct;
         private final Map<String,Object> params;
@@ -194,6 +194,10 @@ public final class WorkflowSensor<T> extends 
AbstractAddTriggerableSensor<T> imp
             }
         }
 
+        public Map<String,Object> getParams() {
+            return params;
+        }
+
         @Override
         public String toString() {
             return "WorkflowPollCallable{" +
diff --git 
a/core/src/test/java/org/apache/brooklyn/util/core/xstream/XmlSerializerTest.java
 
b/core/src/test/java/org/apache/brooklyn/util/core/xstream/XmlSerializerTest.java
index df62549c60..e2c5b950e9 100644
--- 
a/core/src/test/java/org/apache/brooklyn/util/core/xstream/XmlSerializerTest.java
+++ 
b/core/src/test/java/org/apache/brooklyn/util/core/xstream/XmlSerializerTest.java
@@ -32,8 +32,6 @@ import org.apache.brooklyn.util.collections.MutableMap;
 import org.apache.brooklyn.util.collections.MutableSet;
 import org.apache.brooklyn.util.core.config.ConfigBag;
 import 
org.apache.brooklyn.util.core.xstream.LambdaPreventionMapper.LambdaPersistenceMode;
-import org.omg.CORBA.ObjectHolder;
-import org.omg.CORBA.StringHolder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import static org.testng.Assert.assertEquals;

Reply via email to