Блог

хотите посмотреть онлайн-трансляцию твитов, я сначала авторизовал свои учетные данные, затем внедрил метод StatusListener, далее я внедрил метод OnStatus, который предоставил мне переменную status для отображения статуса, я также ввел 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();

    }
}