public abstract class AbstractTwitterConsumerHandler extends Object
Modifier and Type | Field and Description |
---|---|
protected TwitterEndpoint |
endpoint
Instance of TwitterEndpoint.
|
protected org.slf4j.Logger |
log |
Modifier | Constructor and Description |
---|---|
protected |
AbstractTwitterConsumerHandler(TwitterEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
abstract List<org.apache.camel.Exchange> |
directConsume()
Called by direct consumers.
|
protected long |
getLastId() |
protected twitter4j.Paging |
getLastIdPaging() |
protected twitter4j.Twitter |
getTwitter() |
abstract List<org.apache.camel.Exchange> |
pollConsume()
Called by polling consumers during each poll.
|
void |
setLastId(long sinceId)
Support to update the Consumer's lastId when starting the consumer
|
protected void |
setLastIdIfGreater(long newId)
Can't assume that the end of the list will be the most recent ID.
|
protected final org.slf4j.Logger log
protected final TwitterEndpoint endpoint
protected AbstractTwitterConsumerHandler(TwitterEndpoint endpoint)
public abstract List<org.apache.camel.Exchange> pollConsume() throws twitter4j.TwitterException
twitter4j.TwitterException
public abstract List<org.apache.camel.Exchange> directConsume() throws twitter4j.TwitterException
twitter4j.TwitterException
protected void setLastIdIfGreater(long newId)
public void setLastId(long sinceId)
protected twitter4j.Twitter getTwitter()
protected long getLastId()
protected twitter4j.Paging getLastIdPaging()
Apache Camel