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 2017/07/05 09:27:03 UTC
[5/8] camel git commit: Added a bit of logging
Added a bit of logging
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1cb6c033
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1cb6c033
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1cb6c033
Branch: refs/heads/camel-2.19.x
Commit: 1cb6c033c90855de6a19a982f2c5be96ad94e6f9
Parents: 1a23895
Author: Claus Ibsen <da...@apache.org>
Authored: Wed Jul 5 10:59:03 2017 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed Jul 5 11:23:34 2017 +0200
----------------------------------------------------------------------
.../apache/camel/component/twitter/consumer/TwitterConsumer.java | 4 ++++
.../twitter/consumer/timeline/AbstractStatusConsumer.java | 2 +-
.../camel/component/twitter/consumer/timeline/HomeConsumer.java | 2 ++
.../component/twitter/consumer/timeline/MentionsConsumer.java | 2 ++
.../component/twitter/consumer/timeline/RetweetsConsumer.java | 2 ++
.../camel/component/twitter/consumer/timeline/UserConsumer.java | 2 ++
6 files changed, 13 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/1cb6c033/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/TwitterConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/TwitterConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/TwitterConsumer.java
index b1d9b37..ca877c7 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/TwitterConsumer.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/TwitterConsumer.java
@@ -20,6 +20,8 @@ import java.util.List;
import org.apache.camel.Exchange;
import org.apache.camel.component.twitter.TwitterEndpoint;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import twitter4j.Paging;
import twitter4j.Twitter;
import twitter4j.TwitterException;
@@ -27,6 +29,8 @@ import twitter4j.TwitterException;
public abstract class TwitterConsumer {
+ protected final Logger log = LoggerFactory.getLogger(this.getClass());
+
/**
* Instance of TwitterEndpoint.
*/
http://git-wip-us.apache.org/repos/asf/camel/blob/1cb6c033/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java
index 18f0aee..64d6679 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java
@@ -36,7 +36,7 @@ abstract class AbstractStatusConsumer extends TwitterConsumer {
@Override
public List<Exchange> pollConsume() throws TwitterException {
- List<Status> statusList = doPoll();
+ List<Status> statusList = doPoll();
for (int i = 0; i < statusList.size(); i++) {
setLastIdIfGreater(statusList.get(i).getId());
}
http://git-wip-us.apache.org/repos/asf/camel/blob/1cb6c033/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/HomeConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/HomeConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/HomeConsumer.java
index 252bacc..0b2a934 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/HomeConsumer.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/HomeConsumer.java
@@ -33,11 +33,13 @@ public class HomeConsumer extends AbstractStatusConsumer {
@Override
protected List<Status> doPoll() throws TwitterException {
+ log.trace("doPoll.getHomeTimeline(sinceId={})", getLastIdPaging().getSinceId());
return getTwitter().getHomeTimeline(getLastIdPaging());
}
@Override
protected List<Status> doDirect() throws TwitterException {
+ log.trace("doDirect.getHomeTimeline()");
return getTwitter().getHomeTimeline();
}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/1cb6c033/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/MentionsConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/MentionsConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/MentionsConsumer.java
index c3671c8..cf07350 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/MentionsConsumer.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/MentionsConsumer.java
@@ -33,11 +33,13 @@ public class MentionsConsumer extends AbstractStatusConsumer {
@Override
protected List<Status> doPoll() throws TwitterException {
+ log.trace("doPoll.getMentionsTimeline(sinceId={})", getLastIdPaging().getSinceId());
return getTwitter().getMentionsTimeline(getLastIdPaging());
}
@Override
protected List<Status> doDirect() throws TwitterException {
+ log.trace("doDirect.getMentionsTimeline()");
return getTwitter().getMentionsTimeline();
}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/1cb6c033/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/RetweetsConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/RetweetsConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/RetweetsConsumer.java
index dfd0815..585cff9 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/RetweetsConsumer.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/RetweetsConsumer.java
@@ -33,11 +33,13 @@ public class RetweetsConsumer extends AbstractStatusConsumer {
@Override
protected List<Status> doPoll() throws TwitterException {
+ log.trace("doPoll.getRetweetsOfMe(sinceId={})", getLastIdPaging().getSinceId());
return getTwitter().getRetweetsOfMe(getLastIdPaging());
}
@Override
protected List<Status> doDirect() throws TwitterException {
+ log.trace("doDirect.getRetweetsOfMe(");
return getTwitter().getRetweetsOfMe();
}
}
http://git-wip-us.apache.org/repos/asf/camel/blob/1cb6c033/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/UserConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/UserConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/UserConsumer.java
index 51ef02a..ab20665 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/UserConsumer.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/UserConsumer.java
@@ -33,11 +33,13 @@ public class UserConsumer extends AbstractStatusConsumer {
@Override
protected List<Status> doPoll() throws TwitterException {
+ log.trace("doPoll.getUserTimeline(user={}, sinceId={})", endpoint.getProperties().getUser(), getLastIdPaging().getSinceId());
return getTwitter().getUserTimeline(endpoint.getProperties().getUser(), getLastIdPaging());
}
@Override
protected List<Status> doDirect() throws TwitterException {
+ log.trace("doDirect.getUserTimeline(user={})", endpoint.getProperties().getUser());
return getTwitter().getUserTimeline(endpoint.getProperties().getUser());
}
}