CAMEL-6304: Added @UriParam to camel-twitter.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1f2e0d62 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1f2e0d62 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1f2e0d62 Branch: refs/heads/master Commit: 1f2e0d62878ad65bf798708a952bfbb9a92a3eb5 Parents: a324df9 Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Jun 4 17:26:48 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Jun 4 17:26:48 2013 +0200 ---------------------------------------------------------------------- .../component/twitter/TwitterConfiguration.java | 32 +++++++++++--- 1 files changed, 25 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1f2e0d62/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java index fc26ab7..f2df043 100644 --- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java +++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java @@ -20,6 +20,7 @@ import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; +import org.apache.camel.spi.UriParam; import twitter4j.Twitter; import twitter4j.TwitterFactory; import twitter4j.TwitterStream; @@ -32,68 +33,89 @@ public class TwitterConfiguration { /** * OAuth */ + @UriParam private String consumerKey; + @UriParam private String consumerSecret; + @UriParam private String accessToken; + @UriParam private String accessTokenSecret; /** * Defines the Twitter API endpoint. */ + @UriParam private String type; /** * Polling delay. */ + @UriParam private int delay = 60; /** * Username -- used for searching, etc. */ + @UriParam private String user; /** * Keywords used for search and filters. */ + @UriParam private String keywords; /** * Lon/Lat bounding boxes used for filtering. */ + @UriParam private String locations; /** * List of userIds used for searching, etc. */ + @UriParam private String userIds; /** * Filter out old tweets that have been previously polled. */ + @UriParam private boolean filterOld = true; /** * Used for time-based endpoints (trends, etc.) */ + @UriParam private String date; /** * Used to set the sinceId from pulling */ + @UriParam private long sinceId = 1; /** * Used ot set the preferred language on which to search */ + @UriParam private String lang; /** * Used to set the maximum tweets per page (max = 100) */ + @UriParam private Integer count; - + + @UriParam private Date parsedDate; - private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + + /** + * Number of page to iterate before stop (default is 1) + */ + @UriParam + private Integer numberOfPages = new Integer(1); /** * Singleton, on demand instances of Twitter4J's Twitter & TwitterStream. @@ -106,11 +128,6 @@ public class TwitterConfiguration { private TwitterStream twitterStream; /** - * Number of page to iterate before stop (default is 1) - */ - private Integer numberOfPages = new Integer(1); - - /** * Ensures required fields are available. */ public void checkComplete() { @@ -252,6 +269,7 @@ public class TwitterConfiguration { public void setDate(String date) { this.date = date; try { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); parsedDate = sdf.parse(date); } catch (ParseException e) { throw new IllegalArgumentException("date must be in yyyy-mm-dd format!");
