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 2014/09/11 18:38:53 UTC
[2/2] git commit: resolves STREAMS-167 naming consistency
resolves STREAMS-167
naming consistency
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/35a8fbf4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/35a8fbf4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/35a8fbf4
Branch: refs/heads/master
Commit: 35a8fbf4b33fa6f996ed9dd0927ff46aedd85c8f
Parents: 411f0fa
Author: sblackmon <sb...@apache.org>
Authored: Tue Sep 9 19:15:12 2014 -0500
Committer: sblackmon <sb...@apache.org>
Committed: Tue Sep 9 19:15:12 2014 -0500
----------------------------------------------------------------------
.../streams/twitter/processor/FetchAndReplaceTwitterProcessor.java | 2 +-
.../org/apache/streams/twitter/provider/TwitterConfigurator.java | 2 +-
.../org/apache/streams/twitter/provider/TwitterStreamProvider.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/35a8fbf4/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
index 0415efa..4ca73df 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
@@ -62,7 +62,7 @@ public class FetchAndReplaceTwitterProcessor implements StreamsProcessor {
private int retryCount;
public FetchAndReplaceTwitterProcessor() {
- this(TwitterConfigurator.detectConfiguration(StreamsConfigurator.config.getConfig("twitter")));
+ this(TwitterConfigurator.detectTwitterStreamConfiguration(StreamsConfigurator.config.getConfig("twitter")));
}
public FetchAndReplaceTwitterProcessor(TwitterStreamConfiguration config) {
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/35a8fbf4/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java
index 6ba2cda..344fe43 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java
@@ -48,7 +48,7 @@ public class TwitterConfigurator {
}
}
- public static TwitterStreamConfiguration detectConfiguration(Config config) {
+ public static TwitterStreamConfiguration detectTwitterStreamConfiguration(Config config) {
try {
return mapper.readValue(config.root().render(ConfigRenderOptions.concise()), TwitterStreamConfiguration.class);
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/35a8fbf4/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
index 4ca74cd..22532d9 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
@@ -89,7 +89,7 @@ public class TwitterStreamProvider implements StreamsProvider, Serializable, Dat
public TwitterStreamProvider() {
Config config = StreamsConfigurator.config.getConfig("twitter");
- this.config = TwitterConfigurator.detectConfiguration(config);
+ this.config = TwitterConfigurator.detectTwitterStreamConfiguration(config);
}
public TwitterStreamProvider(TwitterStreamConfiguration config) {