streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mfrank...@apache.org
Subject [10/15] git commit: STREAMS-83 | Updated datasift provider with running method
Date Tue, 17 Jun 2014 19:45:53 GMT
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/master
Commit: 42346da25633fdfd8ac096c36cf182a5d065c804
Parents: 5bad0f3
Author: mfranklin <mfranklin@apache.org>
Authored: Thu Jun 12 12:30:41 2014 -0500
Committer: mfranklin <mfranklin@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();


Mime
View raw message