You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/04/14 14:54:52 UTC
camel git commit: CAMEL-6415: camel-twitter - Support for the User
Stream Endpoint. Thanks to Alexandre ESTELA for the patch.
Repository: camel
Updated Branches:
refs/heads/master c2d211b13 -> 34a80fe72
CAMEL-6415: camel-twitter - Support for the User Stream Endpoint. Thanks to Alexandre ESTELA for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/34a80fe7
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/34a80fe7
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/34a80fe7
Branch: refs/heads/master
Commit: 34a80fe72f673499bb8228b086934272e7328f07
Parents: c2d211b
Author: Claus Ibsen <da...@apache.org>
Authored: Tue Apr 14 14:57:45 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue Apr 14 14:57:45 2015 +0200
----------------------------------------------------------------------
.../org/apache/camel/component/twitter/Twitter4JFactory.java | 4 ++++
.../org/apache/camel/component/twitter/data/StreamingType.java | 2 +-
2 files changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/34a80fe7/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/Twitter4JFactory.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/Twitter4JFactory.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/Twitter4JFactory.java
index 5bdfd8c..9025164 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/Twitter4JFactory.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/Twitter4JFactory.java
@@ -23,6 +23,7 @@ import org.apache.camel.component.twitter.consumer.directmessage.DirectMessageCo
import org.apache.camel.component.twitter.consumer.search.SearchConsumer;
import org.apache.camel.component.twitter.consumer.streaming.FilterConsumer;
import org.apache.camel.component.twitter.consumer.streaming.SampleConsumer;
+import org.apache.camel.component.twitter.consumer.streaming.UserStreamingConsumer;
import org.apache.camel.component.twitter.consumer.timeline.HomeConsumer;
import org.apache.camel.component.twitter.consumer.timeline.MentionsConsumer;
import org.apache.camel.component.twitter.consumer.timeline.RetweetsConsumer;
@@ -60,6 +61,7 @@ import org.slf4j.LoggerFactory;
* streaming/
* filter (POLLING ONLY)
* sample (POLLING ONLY)
+ * user (POLLING ONLY)
*/
public final class Twitter4JFactory {
@@ -90,6 +92,8 @@ public final class Twitter4JFactory {
return new SampleConsumer(te);
case FILTER:
return new FilterConsumer(te);
+ case USER:
+ return new UserStreamingConsumer(te);
default:
break;
}
http://git-wip-us.apache.org/repos/asf/camel/blob/34a80fe7/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/data/StreamingType.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/data/StreamingType.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/data/StreamingType.java
index 1056a4b..86f03a4 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/data/StreamingType.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/data/StreamingType.java
@@ -17,7 +17,7 @@
package org.apache.camel.component.twitter.data;
public enum StreamingType {
- SAMPLE, FILTER, UNKNOWN;
+ SAMPLE, FILTER, USER, UNKNOWN;
public static StreamingType fromUri(String uri) {
for (StreamingType streamType : StreamingType.values()) {