Revision 52365
Added by Miriam Baglioni almost 6 years ago
MongoPublisherStore.java | ||
---|---|---|
303 | 303 |
public void run() { |
304 | 304 |
Bson filter = Filters.and(Filters.eq(OAIConfigurationReader.DELETED_FIELD, false), |
305 | 305 |
Filters.lt(OAIConfigurationReader.LAST_COLLECTION_DATE_FIELD, feedDate)); |
306 |
|
|
306 | 307 |
if (!StringUtils.isBlank(source)) { |
307 |
filter = Filters.and(filter, Filters.eq(OAIConfigurationReader.SET_FIELD, source));
|
|
308 |
filter = Filters.and(filter, Filters.eq(OAIConfigurationReader.SET_FIELD, mongoSetCollection.normalizeSetSpec(source)));
|
|
308 | 309 |
} |
309 | 310 |
log.debug("Delete flag query: " + filter); |
310 | 311 |
final BasicDBObject update = new BasicDBObject("$set", |
... | ... | |
682 | 683 |
this.alwaysNewRecord = alwaysNewRecord; |
683 | 684 |
} |
684 | 685 |
|
686 |
|
|
687 |
|
|
685 | 688 |
} |
Also available in: Unified diff
normalized set name in filter constraint