Package | Description |
---|---|
org.dataone.cn.batch.service.v2.impl | |
org.dataone.cn.batch.synchronization.tasks | |
org.dataone.cn.batch.synchronization.type |
Modifier and Type | Class and Description |
---|---|
class |
NodeRegistrySyncServiceImpl |
Modifier and Type | Method and Description |
---|---|
protected void |
ObjectListHarvestTask.spoolToSynchronizationQueue(SortedHarvestTimepointMap harvest,
SyncQueueFacade hzSyncObjectQueue,
NodeRegistrySyncService nodeRegistryService,
Integer requeueTolerance)
Submit the harvest to the sync queue, periodically updating the node's lastHarvestedDate
(able to do this since the pids are already sorted)
|
Modifier and Type | Method and Description |
---|---|
NodeRegistrySyncService |
NodeComm.getNodeRegistryService() |
Modifier and Type | Method and Description |
---|---|
void |
NodeComm.setNodeRegistryService(NodeRegistrySyncService nodeRegistryService) |
Constructor and Description |
---|
NodeComm(Object mnRead,
NodeRegistrySyncService nodeRegistryService) |
NodeComm(Object mnRead,
Object cnRead,
NodeRegistrySyncService nodeRegistryService,
org.dataone.service.cn.v2.CNCore cnCore,
org.dataone.service.cn.v2.CNReplication cnReplication,
IdentifierReservationQueryService reserveIdentifierService) |
Copyright © 2018. All rights reserved.