public abstract class AbstractStreamingConsumerHandler extends AbstractTwitterConsumerHandler implements twitter4j.StatusListener, org.apache.camel.Service
endpoint, log
Constructor and Description |
---|
AbstractStreamingConsumerHandler(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 AbstractStreamingConsumerHandler(TwitterEndpoint te)
public List<org.apache.camel.Exchange> pollConsume() throws twitter4j.TwitterException
AbstractTwitterConsumerHandler
pollConsume
in class AbstractTwitterConsumerHandler
twitter4j.TwitterException
public List<org.apache.camel.Exchange> directConsume() throws twitter4j.TwitterException
AbstractTwitterConsumerHandler
directConsume
in class AbstractTwitterConsumerHandler
twitter4j.TwitterException
public void onException(Exception ex)
onException
in interface twitter4j.StreamListener
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