Add command to print active keywords

1 files changed, 15 insertions, 0 deletions

diff --git a/src/io/StreamImpl.java b/src/io/StreamImpl.java
index fadd335..426d1fa 100644
--- a/src/io/StreamImpl.java
+++ b/src/io/StreamImpl.java
@@ -96,6 +96,21 @@ public class StreamImpl implements Stream {
     }
 
     @Override
+    public Set<String> getKeywords(boolean active) {
+        HashSet<String> retKeywords = new HashSet<>();
+        if (active) {
+            // return keywords from the active connection
+            if (workerContainer != null) {
+                String keywordsStr = workerContainer.getWorker().getKeywords();
+                retKeywords.addAll(Arrays.asList(keywordsStr.split(",")));
+            }
+        } else {
+            retKeywords.addAll(keywords);
+        }
+        return retKeywords;
+    }
+
+    @Override
     public void commit() throws IOException {
         String keywordsStr = StringUtils.join(keywords, ",");
         /* do not reconnect if a connection already exists for the keywords */