Revision 34033
Added by Sandro La Bruzzo over 9 years ago
modules/cnr-mongo-mdstore/trunk/src/main/java/eu/dnetlib/data/mdstore/modular/mongodb/MDStoreTransactionManagerImpl.java | ||
---|---|---|
10 | 10 |
import org.apache.commons.logging.LogFactory; |
11 | 11 |
import org.joda.time.DateTime; |
12 | 12 |
import org.joda.time.Days; |
13 |
import org.junit.Assert; |
|
14 | 13 |
import org.springframework.beans.factory.annotation.Required; |
15 | 14 |
|
16 | 15 |
import com.google.common.collect.Lists; |
... | ... | |
356 | 355 |
|
357 | 356 |
/* |
358 | 357 |
* (non-Javadoc) |
359 |
*
|
|
358 |
* |
|
360 | 359 |
* @see eu.dnetlib.data.mdstore.modular.connector.MDStoreTransactionManager#getInfoForCurrentMdStore(java.lang.String) |
361 | 360 |
*/ |
362 | 361 |
@Override |
... | ... | |
396 | 395 |
|
397 | 396 |
/* |
398 | 397 |
* (non-Javadoc) |
399 |
*
|
|
398 |
* |
|
400 | 399 |
* @see eu.dnetlib.data.mdstore.modular.connector.MDStoreTransactionManager#dropUsed(java.lang.String, java.lang.String) |
401 | 400 |
*/ |
402 | 401 |
@Override |
... | ... | |
424 | 423 |
|
425 | 424 |
/* |
426 | 425 |
* (non-Javadoc) |
427 |
*
|
|
426 |
* |
|
428 | 427 |
* @see eu.dnetlib.data.mdstore.modular.connector.MDStoreTransactionManager#garbage() |
429 | 428 |
*/ |
430 | 429 |
@Override |
... | ... | |
448 | 447 |
for (String collection : collections) { |
449 | 448 |
if (collection.length() > 30 && collection.contains("discarded-") == false) { |
450 | 449 |
final DBObject item = getMetadataObjectForCollections(collection); |
451 |
Assert.assertNotNull(item); |
|
450 |
|
|
452 | 451 |
if (shouldDelete(collection, item)) { |
453 | 452 |
if (log.isDebugEnabled()) { |
454 | 453 |
log.debug("delete collection: " + collection + " from mongo"); |
... | ... | |
688 | 687 |
|
689 | 688 |
/* |
690 | 689 |
* (non-Javadoc) |
691 |
*
|
|
690 |
* |
|
692 | 691 |
* @see eu.dnetlib.data.mdstore.modular.connector.MDStoreTransactionManager#dropTransaction(java.lang.String, java.lang.String) |
693 | 692 |
*/ |
694 | 693 |
@Override |
Also available in: Unified diff
removed wrong import