Permalink
Browse files

Push the start offset to the data provider if set after the provider …

…has been built.
  • Loading branch information...
1 parent a96e7aa commit 3eef6cd5103381bc70fdf4e3217502a2f9752254 @santip santip committed with wonlay Mar 3, 2012
@@ -113,9 +113,15 @@ public DefaultStreamingIndexingManager(SenseiSchema schema,Configuration senseiC
public void updateOldestSinceKey(String sinceKey){
if(_oldestSinceKey == null){
_oldestSinceKey = sinceKey;
+ if (_dataProvider != null) {
+ _dataProvider.setStartingOffset(_oldestSinceKey);
+ }
}
else if(sinceKey!=null && _versionComparator.compare(sinceKey, _oldestSinceKey) <0 ){
_oldestSinceKey = sinceKey;
+ if (_dataProvider != null) {
+ _dataProvider.setStartingOffset(_oldestSinceKey);
+ }
}
}

0 comments on commit 3eef6cd

Please sign in to comment.