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/12 20:08:32 UTC
[09/14] git commit: STREAMS-83 | Updated datasift provider with
running method
STREAMS-83 | Updated datasift 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/42346da2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/42346da2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/42346da2
Branch: refs/heads/STREAMS-83
Commit: 42346da25633fdfd8ac096c36cf182a5d065c804
Parents: 5bad0f3
Author: mfranklin <mf...@apache.org>
Authored: Thu Jun 12 12:30:41 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Thu Jun 12 12:30:41 2014 -0500
----------------------------------------------------------------------
.../streams/datasift/provider/DatasiftStreamProvider.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/42346da2/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftStreamProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftStreamProvider.java b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftStreamProvider.java
index 96466ea..538d8d1 100644
--- a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftStreamProvider.java
+++ b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/provider/DatasiftStreamProvider.java
@@ -190,6 +190,11 @@ public class DatasiftStreamProvider implements StreamsProvider {
}
@Override
+ public boolean isRunning() {
+ return this.clients != null && this.clients.size() > 0;
+ }
+
+ @Override
public void prepare(Object configurationObject) {
this.interactions = new ConcurrentLinkedQueue<Interaction>();
this.clients = Maps.newHashMap();