+package twitter.manage;\r
+\r
+import twitter4j.DirectMessage;\r
+import twitter4j.Status;\r
+import twitter4j.TwitterStream;\r
+import twitter4j.TwitterStreamFactory;\r
+import twitter4j.User;\r
+import twitter4j.UserStreamAdapter;\r
+import twitter4j.auth.AccessToken;\r
+\r
+public class TweetUserStreamManager extends UserStreamAdapter {\r
+\r
+ //streaming\r
+ private TwitterStream twitterStream = null;\r
+\r
+ /**\r
+ *\r
+ * @param consumerKey\r
+ * @param consumerSecret\r
+ * @param ac アクセストークン\r
+ */\r
+ public TweetUserStreamManager(String consumerKey, String consumerSecret, AccessToken ac) {\r
+ this.twitterStream = new TwitterStreamFactory().getInstance();\r
+ this.twitterStream.setOAuthConsumer(consumerKey, consumerSecret);\r
+ this.twitterStream.setOAuthAccessToken(ac);\r
+ this.twitterStream.addListener(this);\r
+ this.twitterStream.user();\r
+ }\r
+\r
+ @Override\r
+ public void onStatus(Status status) {\r
+ if( status.isRetweetedByMe() ) {\r
+ System.out.println( status.getUser().getScreenName() + " Retweet my message");\r
+ }\r
+ System.out.println("@" + status.getUser().getScreenName() + " - "\r
+ + status.getText());\r
+ }\r
+\r
+ @Override\r
+ public void onException(Exception ex) {\r
+ ex.printStackTrace();\r
+ }\r
+\r
+ @Override\r
+ public void onDirectMessage(DirectMessage directmessage) {\r
+ System.out.println("Recipient: "\r
+ + directmessage.getRecipientScreenName() + " from "\r
+ + "Sender : " + directmessage.getSenderScreenName()\r
+ + " text : " + directmessage.getText() );\r
+ }\r
+\r
+ @Override\r
+ public void onFavorite(User source, User target, Status favoritedStatus) {\r
+ System.out.println(source.getScreenName() + " favorited "\r
+ + target.getScreenName() + "'s Status. StatusId: "\r
+ + favoritedStatus.getId() );\r
+ System.out.println("FAV MESSAGE:" + favoritedStatus.getText());\r
+ }\r
+\r
+ @Override\r
+ public void onFriendList(long[] friendIds) {\r
+ String tempString = "FriendIds(Up to 2000): \n";\r
+ int max = 2000;\r
+ int count = friendIds.length;\r
+\r
+ if (count > 0) {\r
+ if (count < max) {\r
+ max = count;\r
+ }\r
+\r
+ for (int i = 0; i < max; i++) {\r
+ tempString += friendIds[i] + " ";\r
+ }\r
+ System.out.println(tempString);\r
+ }\r
+ }\r
+}\r