1

hbc twitter api との切断に対処する方法がわかりません。ドキュメントには、発生したエラーの種類に応じて再接続の試行を遅くする必要があると書かれています。発生したエラーの種類はどこで確認できますか? それはmsgQueueeventQueue またはどこにありますか?

@Asynchronous
@Override
public void makeLatestsTweets() {

    msgList = new LinkedList<Tweet>();

    BlockingQueue<String> msgQueue = new LinkedBlockingQueue<String>(100);
    BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<Event>(100);


    Hosts hosebirdHosts = new HttpHosts(Constants.SITESTREAM_HOST);

    StatusesFilterEndpoint hosebirdEndpoint = new StatusesFilterEndpoint();

    userIds = addFollowings();

    hosebirdEndpoint.followings(userIds);

    Authentication hosebirdAuth = new OAuth1(CONSUMER_KEY, CONSUMER_SECRET,
            TOKEN, SECRET);

    ClientBuilder builder = new ClientBuilder().hosts(hosebirdHosts)
            .authentication(hosebirdAuth).endpoint(hosebirdEndpoint)
            .processor(new StringDelimitedProcessor(msgQueue))
            .eventMessageQueue(eventQueue);

    Client hosebirdClient = builder.build();
    hosebirdClient.connect();
    while (!hosebirdClient.isDone()) {
        try {
            String msg = msgQueue.take();
            Tweet tweet = format(msg);
            if (tweet != null) {
                System.out.println(tweet.getTweetsContent());
                msgList.addFirst(tweet);
                if (msgList.size() > tweetListSize) {
                    msgList.removeLast();
                }
                caller.setMsgList(msgList);
            }
        } catch (InterruptedException e) {
            hosebirdClient.stop();
            e.printStackTrace();
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}
4

0 に答える 0