public abstract class AbstractStreamingConsumer extends TwitterConsumer implements twitter4j.StatusListener, org.apache.camel.Service
endpoint
Constructor and Description |
---|
AbstractStreamingConsumer(TwitterEndpoint te) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.camel.Exchange> |
directConsume()
Called by direct consumers.
|
protected twitter4j.TwitterStream |
getTwitterStream() |
void |
onDeletionNotice(twitter4j.StatusDeletionNotice statusDeletionNotice) |
protected void |
onEvent(org.apache.camel.Exchange exchange) |
void |
onException(Exception ex) |
void |
onScrubGeo(long userId,
long upToStatusId) |
void |
onStatus(twitter4j.Status status) |
void |
onTrackLimitationNotice(int numberOfLimitedStatuses) |
List<org.apache.camel.Exchange> |
pollConsume()
Called by polling consumers during each poll.
|
void |
removeEventListener(TwitterEventListener tweeterStatusListener) |
void |
setEventListener(TwitterEventListener tweeterStatusListener) |
void |
stop() |
getLastId, getLastIdPaging, getTwitter, setLastId, setLastIdIfGreater
public AbstractStreamingConsumer(TwitterEndpoint te)
public List<org.apache.camel.Exchange> pollConsume() throws twitter4j.TwitterException
TwitterConsumer
pollConsume
in class TwitterConsumer
twitter4j.TwitterException
public List<org.apache.camel.Exchange> directConsume() throws twitter4j.TwitterException
TwitterConsumer
directConsume
in class TwitterConsumer
twitter4j.TwitterException
public void onException(Exception ex)
public void onStatus(twitter4j.Status status)
onStatus
in interface twitter4j.StatusListener
public void onDeletionNotice(twitter4j.StatusDeletionNotice statusDeletionNotice)
onDeletionNotice
in interface twitter4j.StatusListener
public void onTrackLimitationNotice(int numberOfLimitedStatuses)
onTrackLimitationNotice
in interface twitter4j.StatusListener
public void onScrubGeo(long userId, long upToStatusId)
onScrubGeo
in interface twitter4j.StatusListener
public void setEventListener(TwitterEventListener tweeterStatusListener)
public void removeEventListener(TwitterEventListener tweeterStatusListener)
public void stop()
stop
in interface org.apache.camel.Service
protected twitter4j.TwitterStream getTwitterStream()
protected void onEvent(org.apache.camel.Exchange exchange)
Apache Camel