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:58 UTC
[15/15] git commit: STREAMS-83 | Updated google provider with running
method
STREAMS-83 | Updated google 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/73ca1e03
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/73ca1e03
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/73ca1e03
Branch: refs/heads/master
Commit: 73ca1e038e4cbdd9580aa651af37c4becb75dc22
Parents: b90f7ce
Author: mfranklin <mf...@apache.org>
Authored: Thu Jun 12 12:53:40 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Thu Jun 12 12:53:40 2014 -0500
----------------------------------------------------------------------
.../main/java/com/google/gmail/provider/GMailProvider.java | 8 +++++++-
.../main/java/com/google/gplus/provider/GPlusProvider.java | 5 +++++
2 files changed, 12 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/73ca1e03/streams-contrib/streams-provider-google/google-gmail/src/main/java/com/google/gmail/provider/GMailProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-google/google-gmail/src/main/java/com/google/gmail/provider/GMailProvider.java b/streams-contrib/streams-provider-google/google-gmail/src/main/java/com/google/gmail/provider/GMailProvider.java
index f57cf2e..19a6407 100644
--- a/streams-contrib/streams-provider-google/google-gmail/src/main/java/com/google/gmail/provider/GMailProvider.java
+++ b/streams-contrib/streams-provider-google/google-gmail/src/main/java/com/google/gmail/provider/GMailProvider.java
@@ -63,6 +63,7 @@ public class GMailProvider implements StreamsProvider, DatumStatusCountable {
protected BlockingQueue inQueue = new LinkedBlockingQueue<String>(10000);
protected volatile Queue<StreamsDatum> providerQueue = new ConcurrentLinkedQueue<StreamsDatum>();
+ protected Future task;
public BlockingQueue<Object> getInQueue() {
return inQueue;
@@ -105,7 +106,7 @@ public class GMailProvider implements StreamsProvider, DatumStatusCountable {
@Override
public void startStream() {
- executor.submit(new GMailImapProviderTask(this));
+ task = executor.submit(new GMailImapProviderTask(this));
}
@@ -137,6 +138,11 @@ public class GMailProvider implements StreamsProvider, DatumStatusCountable {
}
@Override
+ public boolean isRunning() {
+ return !task.isDone() && !task.isCancelled();
+ }
+
+ @Override
public void prepare(Object configurationObject) {
Preconditions.checkNotNull(this.klass);
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/73ca1e03/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusProvider.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusProvider.java
index a5a504b..9257783 100644
--- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusProvider.java
+++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusProvider.java
@@ -148,6 +148,11 @@ public class GPlusProvider implements StreamsProvider {
}
@Override
+ public boolean isRunning() {
+ return !providerTaskComplete.isDone() && !providerTaskComplete.isCancelled();
+ }
+
+ @Override
public void prepare(Object configurationObject) {
Preconditions.checkNotNull(this.klass);