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 2015/08/18 21:28:04 UTC
[2/5] incubator-streams git commit: consolidated
consolidated
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/b79cc7fb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/b79cc7fb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/b79cc7fb
Branch: refs/heads/master
Commit: b79cc7fbe73be397ebe68833ba19332aefe71215
Parents: 5027a06
Author: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Authored: Mon Jul 27 11:27:38 2015 -0500
Committer: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Committed: Mon Jul 27 11:27:38 2015 -0500
----------------------------------------------------------------------
.../twitter/provider/TwitterProviderUtil.java | 25 ++++++++++++++++++++
.../provider/TwitterTimelineProvider.java | 11 +--------
.../TwitterUserInformationProvider.java | 11 +--------
3 files changed, 27 insertions(+), 20 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/b79cc7fb/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterProviderUtil.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterProviderUtil.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterProviderUtil.java
new file mode 100644
index 0000000..ec5f256
--- /dev/null
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterProviderUtil.java
@@ -0,0 +1,25 @@
+package org.apache.streams.twitter.provider;
+
+import org.apache.streams.twitter.TwitterUserInformationConfiguration;
+
+/**
+ * Created by sblackmon on 7/26/15.
+ */
+public class TwitterProviderUtil {
+
+ public static String baseUrl(TwitterUserInformationConfiguration config) {
+
+ String baseUrl = new StringBuilder()
+ .append(config.getProtocol())
+ .append("://")
+ .append(config.getHost())
+ .append(":")
+ .append(config.getPort())
+ .append("/")
+ .append(config.getVersion())
+ .append("/")
+ .toString();
+
+ return baseUrl;
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/b79cc7fb/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
index 8f5fa24..c05daf5 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
@@ -275,16 +275,7 @@ public class TwitterTimelineProvider implements StreamsProvider, Serializable {
public Twitter getTwitterClient() {
- String baseUrl = new StringBuilder()
- .append(config.getProtocol())
- .append("://")
- .append(config.getHost())
- .append(":")
- .append(config.getPort())
- .append("/")
- .append(config.getVersion())
- .append("/")
- .toString();
+ String baseUrl = TwitterProviderUtil.baseUrl(twitterUserInformationConfiguration);
ConfigurationBuilder builder = new ConfigurationBuilder()
.setOAuthConsumerKey(config.getOauth().getConsumerKey())
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/b79cc7fb/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java
index 0a7fe58..9def663 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java
@@ -288,16 +288,7 @@ public class TwitterUserInformationProvider implements StreamsProvider, Serializ
protected Twitter getTwitterClient()
{
- String baseUrl = new StringBuilder()
- .append(twitterUserInformationConfiguration.getProtocol())
- .append("://")
- .append(twitterUserInformationConfiguration.getHost())
- .append(":")
- .append(twitterUserInformationConfiguration.getPort())
- .append("/")
- .append(twitterUserInformationConfiguration.getVersion())
- .append("/")
- .toString();
+ String baseUrl = TwitterProviderUtil.baseUrl(twitterUserInformationConfiguration);
ConfigurationBuilder builder = new ConfigurationBuilder()
.setOAuthConsumerKey(twitterUserInformationConfiguration.getOauth().getConsumerKey())