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 <davscl...@apache.org> Authored: Tue Apr 14 14:57:45 2015 +0200 Committer: Claus Ibsen <davscl...@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()) {
