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

removed 'lastPage' boolean flag from SearchResults since it was never being used (was always false)

Browse Source
This commit is contained in:
Mark Fisher
2010-11-18 21:49:01 -05:00
parent 262adbaeab
commit d04c0be68a
3 changed files with 5 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-integration-twitter/src/main/java/org/springframework/integration/twitter/core/SearchResults.java
View File

@@ -32,14 +32,11 @@ public class SearchResults {
private long sinceId;
private boolean lastPage;
public SearchResults(List<Tweet> tweets, long maxId, long sinceId, boolean lastPage) {
public SearchResults(List<Tweet> tweets, long maxId, long sinceId) {
this.tweets = tweets;
this.maxId = maxId;
this.sinceId = sinceId;
this.lastPage = lastPage;
}
@@ -64,12 +61,4 @@ public class SearchResults {
return sinceId;
}
/**
* Returns <code>true</code> if this is the last page of matching {@link Tweet}s,
* <code>false</code> if there are more pages that follow this one.
*/
public boolean isLastPage() {
return lastPage;
}
}

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

@@ -204,7 +204,7 @@ public class Twitter4jTemplate implements TwitterOperations {
if (result != null) {
List<twitter4j.Tweet> t4jTweets = result.getTweets();
List<Tweet> tweets = this.buildTweetsFromTwitterResponses(t4jTweets);
SearchResults results = new SearchResults(tweets, result.getMaxId(), result.getSinceId(), false);
SearchResults results = new SearchResults(tweets, result.getMaxId(), result.getSinceId());
return results;
}
}

6
spring-integration-twitter/src/main/java/org/springframework/integration/twitter/inbound/AbstractTwitterMessageSource.java
View File

@@ -70,7 +70,7 @@ abstract class AbstractTwitterMessageSource<T> extends IntegrationObjectSupport
private final TweetComparator tweetComparator = new TweetComparator();
private final Object markerGuard = new Object();
private final Object lastEnqueuedIdMonitor = new Object();
public AbstractTwitterMessageSource(TwitterOperations twitterOperations) {
@@ -148,11 +148,11 @@ abstract class AbstractTwitterMessageSource<T> extends IntegrationObjectSupport
}
private void enqueue(Tweet tweet) {
synchronized (this.markerGuard) {
synchronized (this.lastEnqueuedIdMonitor) {
long id = tweet.getId();
if (id > this.lastEnqueuedId) {
this.lastEnqueuedId = id;
this.tweets.add(tweet);
this.lastEnqueuedId = id;
}
}
}