You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2016/10/24 00:35:48 UTC
incubator-streams git commit: Squashed commit of the following:
Repository: incubator-streams
Updated Branches:
refs/heads/master 094ba0e32 -> 0c4087ca6
Squashed commit of the following:
commit d7db3b7470175c7320ee2ed39013ef1c4668fbcf
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Date: Sun Oct 23 19:29:42 2016 -0500
STREAMS-436: Fix the bug causing instagram IT to stall
commit 4363b19a381bbda053a2cce1f96a626fb81d3dd7
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Date: Sun Oct 23 19:29:24 2016 -0500
STREAMS-436: Put a timeout on all Provider Integration Tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/0c4087ca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/0c4087ca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/0c4087ca
Branch: refs/heads/master
Commit: 0c4087ca6ec95765f6adc7b28fcc0ad265f747b8
Parents: 094ba0e
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Authored: Sun Oct 23 19:34:13 2016 -0500
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
Committed: Sun Oct 23 19:34:13 2016 -0500
----------------------------------------------------------------------
.../providers/page/FacebookPageProviderIT.java | 18 ++++++++++++++
.../pagefeed/FacebookPageFeedProviderIT.java | 19 +++++++++++++--
.../providers/GPlusUserActivityProviderIT.java | 19 +++++++++++++--
.../test/providers/GPlusUserDataProviderIT.java | 18 ++++++++++++++
.../provider/InstagramAbstractProvider.java | 1 +
.../InstagramRecentMediaProviderIT.java | 16 ++++++++++---
.../providers/InstagramUserInfoProviderIT.java | 16 ++++++++++---
.../providers/TwitterFollowingProviderIT.java | 19 +++++++++++++--
.../test/providers/TwitterStreamProviderIT.java | 25 +++++++++++---------
.../providers/TwitterTimelineProviderIT.java | 19 +++++++++++++--
.../TwitterUserInformationProviderIT.java | 19 +++++++++++++--
.../providers/YoutubeChannelProviderIT.java | 19 +++++++++++++--
.../YoutubeUserActivityProviderIT.java | 19 +++++++++++++--
13 files changed, 196 insertions(+), 31 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/page/FacebookPageProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/page/FacebookPageProviderIT.java b/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/page/FacebookPageProviderIT.java
index dea1584..4a0cb0e 100644
--- a/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/page/FacebookPageProviderIT.java
+++ b/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/page/FacebookPageProviderIT.java
@@ -21,6 +21,8 @@ package org.apache.streams.facebook.test.providers.page;
import com.google.common.collect.Lists;
import org.apache.streams.facebook.provider.page.FacebookPageProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,12 +30,28 @@ import java.io.LineNumberReader;
public class FacebookPageProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(FacebookPageProviderIT.class);
+
@Test
public void testFacebookPageProvider() throws Exception {
String configfile = "./target/test-classes/FacebookPageProviderIT.conf";
String outfile = "./target/test-classes/FacebookPageProviderIT.stdout.txt";
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ FacebookPageProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
+
FacebookPageProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
File out = new File(outfile);
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/pagefeed/FacebookPageFeedProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/pagefeed/FacebookPageFeedProviderIT.java b/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/pagefeed/FacebookPageFeedProviderIT.java
index 091fc6c..42e7289 100644
--- a/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/pagefeed/FacebookPageFeedProviderIT.java
+++ b/streams-contrib/streams-provider-facebook/src/test/java/org/apache/streams/facebook/test/providers/pagefeed/FacebookPageFeedProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.facebook.test.providers.pagefeed;
-import com.google.common.collect.Lists;
import org.apache.streams.facebook.provider.pagefeed.FacebookPageFeedProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,13 +29,27 @@ import java.io.LineNumberReader;
public class FacebookPageFeedProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(FacebookPageFeedProviderIT.class);
+
@Test
public void testFacebookPageFeedProvider() throws Exception {
String configfile = "./target/test-classes/FacebookPageFeedProviderIT.conf";
String outfile = "./target/test-classes/FacebookPageFeedProviderIT.stdout.txt";
- FacebookPageFeedProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ FacebookPageFeedProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserActivityProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserActivityProviderIT.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserActivityProviderIT.java
index 9fc470e..978dd73 100644
--- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserActivityProviderIT.java
+++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserActivityProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.gplus.test.providers;
-import com.google.common.collect.Lists;
import com.google.gplus.provider.GPlusUserActivityProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,13 +29,27 @@ import java.io.LineNumberReader;
public class GPlusUserActivityProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(GPlusUserActivityProviderIT.class);
+
@Test
public void testGPlusUserActivityProvider() throws Exception {
String configfile = "./target/test-classes/GPlusUserActivityProviderIT.conf";
String outfile = "./target/test-classes/GPlusUserActivityProviderIT.stdout.txt";
- GPlusUserActivityProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ GPlusUserActivityProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserDataProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserDataProviderIT.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserDataProviderIT.java
index f4b7a66..4c60475 100644
--- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserDataProviderIT.java
+++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/test/providers/GPlusUserDataProviderIT.java
@@ -21,6 +21,8 @@ package org.apache.streams.gplus.test.providers;
import com.google.common.collect.Lists;
import com.google.gplus.provider.GPlusUserDataProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,12 +30,28 @@ import java.io.LineNumberReader;
public class GPlusUserDataProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(GPlusUserDataProviderIT.class);
+
@Test
public void testGPlusUserDataProvider() throws Exception {
String configfile = "./target/test-classes/GPlusUserDataProviderIT.conf";
String outfile = "./target/test-classes/GPlusUserDataProviderIT.stdout.txt";
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ GPlusUserDataProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
+
GPlusUserDataProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
File out = new File(outfile);
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramAbstractProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramAbstractProvider.java b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramAbstractProvider.java
index fbba2a2..0c7ba95 100644
--- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramAbstractProvider.java
+++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramAbstractProvider.java
@@ -93,6 +93,7 @@ public abstract class InstagramAbstractProvider implements StreamsProvider {
this.executorService = MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor());
ListenableFuture future = this.executorService.submit(dataCollector);
this.futures.add(future);
+ executorService.shutdown();
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramRecentMediaProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramRecentMediaProviderIT.java b/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramRecentMediaProviderIT.java
index b5169cb..9c81478 100644
--- a/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramRecentMediaProviderIT.java
+++ b/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramRecentMediaProviderIT.java
@@ -18,10 +18,10 @@
package org.apache.streams.instagram.test.providers;
-import com.google.common.collect.Lists;
import org.apache.streams.instagram.provider.recentmedia.InstagramRecentMediaProvider;
-import org.apache.streams.instagram.provider.userinfo.InstagramUserInfoProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -32,6 +32,8 @@ import java.io.LineNumberReader;
*/
public class InstagramRecentMediaProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(InstagramRecentMediaProviderIT.class);
+
@Test
public void testInstagramRecentMediaProvider() throws Exception {
@@ -42,7 +44,15 @@ public class InstagramRecentMediaProviderIT {
args[0] = configfile;
args[1] = outfile;
- InstagramRecentMediaProvider.main(args);
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ InstagramRecentMediaProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramUserInfoProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramUserInfoProviderIT.java b/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramUserInfoProviderIT.java
index c212cc4..a7badcb 100644
--- a/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramUserInfoProviderIT.java
+++ b/streams-contrib/streams-provider-instagram/src/test/java/org/apache/streams/instagram/test/providers/InstagramUserInfoProviderIT.java
@@ -18,10 +18,10 @@
package org.apache.streams.instagram.test.providers;
-import com.google.common.collect.Lists;
-import org.apache.streams.instagram.provider.recentmedia.InstagramRecentMediaProvider;
import org.apache.streams.instagram.provider.userinfo.InstagramUserInfoProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -32,6 +32,8 @@ import java.io.LineNumberReader;
*/
public class InstagramUserInfoProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(InstagramUserInfoProviderIT.class);
+
@Test
public void testInstagramUserInfoProvider() throws Exception {
@@ -42,7 +44,15 @@ public class InstagramUserInfoProviderIT {
args[0] = configfile;
args[1] = outfile;
- InstagramUserInfoProvider.main(args);
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ InstagramUserInfoProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterFollowingProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterFollowingProviderIT.java b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterFollowingProviderIT.java
index 558bb7c..91cdfe1 100644
--- a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterFollowingProviderIT.java
+++ b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterFollowingProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.twitter.test.providers;
-import com.google.common.collect.Lists;
import org.apache.streams.twitter.provider.TwitterFollowingProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,13 +29,27 @@ import java.io.LineNumberReader;
public class TwitterFollowingProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(TwitterFollowingProviderIT.class);
+
@Test
public void testTwitterFollowingProvider() throws Exception {
String configfile = "./target/test-classes/TwitterFollowingProviderIT.conf";
String outfile = "./target/test-classes/TwitterFollowingProviderIT.stdout.txt";
- TwitterFollowingProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ TwitterFollowingProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterStreamProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterStreamProviderIT.java b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterStreamProviderIT.java
index 880f5df..5627b12 100644
--- a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterStreamProviderIT.java
+++ b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterStreamProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.twitter.test.providers;
-import com.google.common.collect.Lists;
import org.apache.streams.twitter.provider.TwitterStreamProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,23 +29,25 @@ import java.io.LineNumberReader;
public class TwitterStreamProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(TwitterStreamProviderIT.class);
+
final String outfile = "./target/test-classes/TwitterStreamProviderIT.stdout.txt";
+ final String configfile = "./target/test-classes/TwitterStreamProviderIT.conf";
@Test
public void testTwitterStreamProvider() throws Exception {
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
- Thread testThread = new Thread(
- new Runnable() {
-
- String configfile = "./target/test-classes/TwitterStreamProviderIT.conf";
-
- @Override
- public void run() {
- TwitterStreamProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
- }
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ TwitterStreamProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
}
- );
+ });
testThread.start();
testThread.join(30000);
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterTimelineProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterTimelineProviderIT.java b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterTimelineProviderIT.java
index 9e26528..7becd2c 100644
--- a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterTimelineProviderIT.java
+++ b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterTimelineProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.twitter.test.providers;
-import com.google.common.collect.Lists;
import org.apache.streams.twitter.provider.TwitterTimelineProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,13 +29,27 @@ import java.io.LineNumberReader;
public class TwitterTimelineProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(TwitterTimelineProviderIT.class);
+
@Test
public void testTwitterTimelineProvider() throws Exception {
String configfile = "./target/test-classes/TwitterTimelineProviderIT.conf";
String outfile = "./target/test-classes/TwitterTimelineProviderIT.stdout.txt";
- TwitterTimelineProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ TwitterTimelineProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterUserInformationProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterUserInformationProviderIT.java b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterUserInformationProviderIT.java
index e489f64..c285840 100644
--- a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterUserInformationProviderIT.java
+++ b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/providers/TwitterUserInformationProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.twitter.test.providers;
-import com.google.common.collect.Lists;
import org.apache.streams.twitter.provider.TwitterUserInformationProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -28,13 +29,27 @@ import java.io.LineNumberReader;
public class TwitterUserInformationProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(TwitterUserInformationProviderIT.class);
+
@Test
public void testTwitterUserInformationProvider() throws Exception {
String configfile = "./target/test-classes/TwitterUserInformationProviderIT.conf";
String outfile = "./target/test-classes/TwitterUserInformationProviderIT.stdout.txt";
- TwitterUserInformationProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ TwitterUserInformationProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeChannelProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeChannelProviderIT.java b/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeChannelProviderIT.java
index 320024a..31e9bb0 100644
--- a/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeChannelProviderIT.java
+++ b/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeChannelProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.youtube.test.providers;
-import com.google.common.collect.Lists;
import com.youtube.provider.YoutubeChannelProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -31,13 +32,27 @@ import java.io.LineNumberReader;
*/
public class YoutubeChannelProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(YoutubeChannelProviderIT.class);
+
@Test
public void testYoutubeChannelProvider() throws Exception {
String configfile = "./target/test-classes/YoutubeChannelProviderIT.conf";
String outfile = "./target/test-classes/YoutubeChannelProviderIT.stdout.txt";
- YoutubeChannelProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ YoutubeChannelProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/0c4087ca/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeUserActivityProviderIT.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeUserActivityProviderIT.java b/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeUserActivityProviderIT.java
index e71a6d1..45d89fa 100644
--- a/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeUserActivityProviderIT.java
+++ b/streams-contrib/streams-provider-youtube/src/test/java/org/apache/streams/youtube/test/providers/YoutubeUserActivityProviderIT.java
@@ -18,9 +18,10 @@
package org.apache.streams.youtube.test.providers;
-import com.google.common.collect.Lists;
import com.youtube.provider.YoutubeUserActivityProvider;
import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileReader;
@@ -31,13 +32,27 @@ import java.io.LineNumberReader;
*/
public class YoutubeUserActivityProviderIT {
+ private static final Logger LOGGER = LoggerFactory.getLogger(YoutubeUserActivityProviderIT.class);
+
@Test
public void testYoutubeUserActivityProvider() throws Exception {
String configfile = "./target/test-classes/YoutubeUserActivityProviderIT.conf";
String outfile = "./target/test-classes/YoutubeUserActivityProviderIT.stdout.txt";
- YoutubeUserActivityProvider.main(Lists.newArrayList(configfile, outfile).toArray(new String[2]));
+ String[] args = new String[2];
+ args[0] = configfile;
+ args[1] = outfile;
+
+ Thread testThread = new Thread((Runnable) () -> {
+ try {
+ YoutubeUserActivityProvider.main(args);
+ } catch( Exception e ) {
+ LOGGER.error("Test Exception!", e);
+ }
+ });
+ testThread.start();
+ testThread.join(30000);
File out = new File(outfile);
assert (out.exists());