Package fr.gouv.vitam.processing.distributor.core

Class AsyncResourceCleaner

java.lang.Object

fr.gouv.vitam.processing.distributor.core.AsyncResourceCleaner

public class AsyncResourceCleaner
extends java.lang.Object

Helper service that handles background cleanup of unused asynchronous resources from storage engine. This service is used for all workflows that require async resource from tape offers.

Constructor Summary

Constructors

Constructor	Description
AsyncResourceCleaner(ServerConfiguration serverConfiguration)
AsyncResourceCleaner(ServerConfiguration serverConfiguration, StorageClientFactory storageClientFactory, java.util.concurrent.ScheduledExecutorService scheduledExecutorService)

Method Summary

Modifier and Type	Method	Description
void	markAsyncResourcesForRemoval(java.util.Map<java.lang.String,AccessRequestContext> asyncResources)	Add async resources to clear

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncResourceCleaner

public AsyncResourceCleaner(ServerConfiguration serverConfiguration)

AsyncResourceCleaner

public AsyncResourceCleaner(ServerConfiguration serverConfiguration,
                            StorageClientFactory storageClientFactory,
                            java.util.concurrent.ScheduledExecutorService scheduledExecutorService)

Method Detail

markAsyncResourcesForRemoval

public void markAsyncResourcesForRemoval(java.util.Map<java.lang.String,AccessRequestContext> asyncResources)

Add async resources to clear

Parameters:

asyncResources - the async resources by request id map