Repository: incubator-streams Updated Branches: refs/heads/master 094ba0e32 -> 0c4087ca6
Squashed commit of the following: commit d7db3b7470175c7320ee2ed39013ef1c4668fbcf Author: Steve Blackmon @steveblackmon <[email protected]> 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 <[email protected]> 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 <[email protected]> Authored: Sun Oct 23 19:34:13 2016 -0500 Committer: Steve Blackmon @steveblackmon <[email protected]> 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());
