хочу видеть потоковую передачу твитов в сети, сначала я авторизовал свои учетные данные, а затем внедрил метод StatusListener. Затем я реализовал метод onStatus, который дал мне переменную состояния для отображения статуса, я также ввел TwitterStream, но я не вижу твиты, я однажды смог чтобы увидеть твиты вчера, когда я добавил точку останова, но теперь она больше не переходит на точку останова, мой код такой, как показано ниже
package com.example.mapo;
import twitter4j.FilterQuery;
import twitter4j.StallWarning;
import twitter4j.Status;
import twitter4j.StatusDeletionNotice;
import twitter4j.StatusListener;
import twitter4j.TwitterStream;
import twitter4j.TwitterStreamFactory;
import twitter4j.User;
import twitter4j.conf.ConfigurationBuilder;
public class SimpleStream {
public static void main(String[] args) {
ConfigurationBuilder cb = new ConfigurationBuilder();
cb.setDebugEnabled(true);
cb.setOAuthConsumerKey("**************");
cb.setOAuthConsumerSecret("*****************************");
cb.setOAuthAccessToken("***************************");
cb.setOAuthAccessTokenSecret("*******************");
TwitterStream twitterStream = new TwitterStreamFactory(cb.build()).getInstance();
StatusListener listener = new StatusListener() {
@Override
public void onException(Exception e) {
}
@Override
public void onStatus(Status status) {
User user = status.getUser();
// gets Username
String username = status.getUser().getScreenName();
System.out.println(username);
String profileLocation = user.getLocation();
System.out.println(profileLocation);
long tweetId = status.getId();
System.out.println(tweetId);
String content = status.getText();
System.out.println(content +"\n");
}
@Override
public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {
}
@Override
public void onTrackLimitationNotice(int i) {
}
@Override
public void onScrubGeo(long l, long l1) {
}
@Override
public void onStallWarning(StallWarning stallWarning) {
}
};
FilterQuery fq = new FilterQuery();
String keywords[] = {"ireland"};
fq.track(keywords);
twitterStream.addListener(listener);
twitterStream.filter(fq);
System.out.println(twitterStream.sample());
twitterStream.cleanUp();
twitterStream.shutdown();
}
}