You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/06/17 21:45:48 UTC
[05/15] git commit: STREAMS-83 | Updated Console provider with
running method
STREAMS-83 | Updated Console provider with running method
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/8bdb63c5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/8bdb63c5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/8bdb63c5
Branch: refs/heads/master
Commit: 8bdb63c5a244c91ebf9819c2a13726a50edb5c85
Parents: 89b191e
Author: mfranklin <mf...@apache.org>
Authored: Thu Jun 12 11:40:13 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Thu Jun 12 11:40:13 2014 -0500
----------------------------------------------------------------------
.../java/org/apache/streams/console/ConsolePersistReader.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/8bdb63c5/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
index e2eb646..776d5a3 100644
--- a/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
+++ b/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistReader.java
@@ -104,4 +104,9 @@ public class ConsolePersistReader implements StreamsPersistReader {
public StreamsResultSet readRange(DateTime start, DateTime end) {
return readCurrent();
}
+
+ @Override
+ public boolean isRunning() {
+ return true; //Will always be running
+ }
}