Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1602 changed to receive HOME Timeline updates instead of Friends

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-11-11 10:07:59 -05:00
parent 834f6ca265
commit 8c63cc003a
5 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-integration-twitter/src/main/java/org/springframework/integration/twitter/core/Twitter4jTemplate.java
View File

@@ -115,9 +115,9 @@ public class Twitter4jTemplate implements TwitterOperations{
}
}
@Override
public List<Tweet> getFriendsTimeline() {
public List<Tweet> getHomeTimeline() {
try {
ResponseList<Status> timelines = twitter.getFriendsTimeline();
ResponseList<Status> timelines = twitter.getHomeTimeline();
return this.buildTweetsFromTwitterResponses(timelines);
}
catch (Exception e) {
@@ -125,9 +125,9 @@ public class Twitter4jTemplate implements TwitterOperations{
}
}
@Override
public List<Tweet> getFriendsTimeline(long sinceId) {
public List<Tweet> getHomeTimeline(long sinceId) {
try {
ResponseList<Status> timelines = twitter.getFriendsTimeline(new Paging(sinceId));
ResponseList<Status> timelines = twitter.getHomeTimeline(new Paging(sinceId));
return this.buildTweetsFromTwitterResponses(timelines);
}
catch (Exception e) {

4
spring-integration-twitter/src/main/java/org/springframework/integration/twitter/core/TwitterOperations.java
View File

@@ -36,9 +36,9 @@ public interface TwitterOperations {
List<Tweet> getMentions(long sinceId);
List<Tweet> getFriendsTimeline();
List<Tweet> getHomeTimeline();
List<Tweet> getFriendsTimeline(long sinceId);
List<Tweet> getHomeTimeline(long sinceId);
void sendDirectMessage(String userName, String text);

4
spring-integration-twitter/src/main/java/org/springframework/integration/twitter/inbound/TimelineUpdateReceivingMessageSource.java
View File

@@ -48,8 +48,8 @@ public class TimelineUpdateReceivingMessageSource extends AbstractTwitterMessage
long sinceId = getMarkerId();
if (tweets.size() <= prefetchThreshold){
List<Tweet> tweets = !hasMarkedStatus()
? twitter.getFriendsTimeline()
: twitter.getFriendsTimeline(sinceId);
? twitter.getHomeTimeline()
: twitter.getHomeTimeline(sinceId);
forwardAll(tweets);
}
} catch (Exception e) {

8
spring-integration-twitter/src/test/java/org/springframework/integration/twitter/core/Twitter4jTemplateTests.java
View File

@@ -89,10 +89,10 @@ public class Twitter4jTemplateTests {
@Test
public void testGetFriendsTimeline() throws Exception{
template.getFriendsTimeline();
template.getFriendsTimeline(123);
verify(twitter, times(1)).getFriendsTimeline();
verify(twitter, times(1)).getFriendsTimeline(Mockito.any(Paging.class));
template.getHomeTimeline();
template.getHomeTimeline(123);
verify(twitter, times(1)).getHomeTimeline();
verify(twitter, times(1)).getHomeTimeline(Mockito.any(Paging.class));
}
@Test

6
spring-integration-twitter/src/test/java/org/springframework/integration/twitter/inbound/TimelineUpdateReceivingMessageSourceTests.java
View File

@@ -131,7 +131,7 @@ public class TimelineUpdateReceivingMessageSourceTests {
Tweet message = (Tweet) msg.poll();
assertEquals(2000, message.getId());
Thread.sleep(1000);
verify(twitter, times(1)).getFriendsTimeline(2000);
verify(twitter, times(1)).getHomeTimeline(2000);
// based on the Mock, the Queue shoud now have 2 mopre messages third and fourth
assertTrue(((Queue)TestUtils.getPropertyValue(source, "tweets")).size() == 2);
source.stop();
@@ -209,12 +209,12 @@ public class TimelineUpdateReceivingMessageSourceTests {
SampleResoponceList testMessages = new SampleResoponceList();
testMessages.add(firstMessage);
testMessages.add(secondMessage);
when(tw.getFriendsTimeline()).thenReturn(testMessages);
when(tw.getHomeTimeline()).thenReturn(testMessages);
testMessages = new SampleResoponceList();
testMessages.add(thirdMessage);
testMessages.add(fourthMessage);
when(tw.getFriendsTimeline(Mockito.any(Paging.class))).thenReturn(testMessages);
when(tw.getHomeTimeline(Mockito.any(Paging.class))).thenReturn(testMessages);
}
@SuppressWarnings({ "rawtypes", "serial" })