That was a debugging statement, pardon.
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/361d122a Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/361d122a Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/361d122a Branch: refs/heads/master Commit: 361d122a5a8c93064e10f8c1817a8268d0bea3ea Parents: 1a03d5f Author: Matthew Hager <matthew.ha...@gmail.com> Authored: Mon May 5 17:22:20 2014 -0500 Committer: Matthew Hager <matthew.ha...@gmail.com> Committed: Mon May 5 17:22:20 2014 -0500 ---------------------------------------------------------------------- .../provider/TwitterStreamConfigurator.java | 19 +------------------ 1 file changed, 1 insertion(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/361d122a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamConfigurator.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamConfigurator.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamConfigurator.java index 5435f24..7c7ef1b 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamConfigurator.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamConfigurator.java @@ -9,7 +9,6 @@ import org.apache.streams.twitter.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.util.ArrayList; import java.util.List; /** @@ -76,23 +75,7 @@ public class TwitterStreamConfigurator { } public static TwitterUserInformationConfiguration detectTwitterUserInformationConfiguration(Config config) { - - TwitterUserInformationConfiguration twitterUserInformationConfiguration = mapper.convertValue(detectTwitterConfiguration(config), TwitterUserInformationConfiguration.class); - - try { - if(config.hasPath("info")) - { - List<String> info = new ArrayList<String>(); - - for (String s : config.getStringList("info")) - info.add(s); - } - } - catch(Exception e) { - LOGGER.error("There was an error: {}", e.getMessage()); - } - - return twitterUserInformationConfiguration; + return mapper.convertValue(detectTwitterConfiguration(config), TwitterUserInformationConfiguration.class); } }
