• R/O
  • SSH
  • HTTPS

nt-manager: Commit


Commit MetaInfo

Revision176 (tree)
Time2011-08-27 02:36:37
Authorspark_xp

Log Message

TweetSearchStreaming内に、重複した余計なコードが存在したため削除

Change Summary

Incremental Difference

--- NishioTweetManager/trunk/src/twitter/manage/TweetSearchStream.java (revision 175)
+++ NishioTweetManager/trunk/src/twitter/manage/TweetSearchStream.java (revision 176)
@@ -31,8 +31,6 @@
3131 private TwitterStream twitterStream = null;
3232 //Filter query
3333 private FilterQuery filter = null;
34- //登録されている検索ワード
35- private Set<String> filterWords = null;
3634 //status stream
3735 private StatusStream statusStream = null;
3836 //Thread
@@ -41,8 +39,12 @@
4139 private TweetManager tweetManager = null;
4240 //検索ワードに対応したリスナー
4341 private Map<String, TweetStreamingListener> listeners = null;
42+ //指定したユーザに対応したリスナー
43+ private Map<Long, TweetStreamingListener> userListener = null;
4444 //指定したワードの最終更新id
4545 private Map<String, Long> lastUpdate = null;
46+ //指定したユーザの最終更新id
47+ private Map<Long, Long> userLastUpdate = null;
4648
4749 /**
4850 *
@@ -58,9 +60,10 @@
5860 this.twitterStream.setOAuthAccessToken(ac);
5961
6062 filter = new FilterQuery();
61- filterWords = new HashSet<String>();
6263 listeners = new HashMap<String, TweetStreamingListener>();
64+ userListener = new HashMap<Long, TweetStreamingListener>();
6365 lastUpdate = new HashMap<String, Long>();
66+ userLastUpdate = new HashMap<Long, Long>();
6467 }
6568
6669 /**
@@ -68,7 +71,6 @@
6871 * @param word
6972 */
7073 public void addSearchWord(String word, TweetStreamingListener listener) {
71- filterWords.add(word);
7274 listeners.put(word, listener);
7375 updateFilter();
7476 }
@@ -78,16 +80,19 @@
7880 * @param word
7981 */
8082 public void removeSearchWord(String word) {
81- filterWords.remove(word);
8283 listeners.remove(word);
8384 updateFilter();
8485 }
8586
87+ public void addUserSearch(Long userid, TweetStreamingListener listener) {
88+
89+ }
90+
8691 /**
8792 * filterの更新
8893 */
8994 private void updateFilter() {
90- String[] words = filterWords.toArray(new String[0]);
95+ String[] words = listeners.keySet().toArray(new String[0]);
9196 filter.track(words);
9297 try {
9398 if( statusStream != null ) {
Show on old repository browser