Package ca.uhn.fhir.jpa.delete

Class ThreadSafeResourceDeleterSvc

java.lang.Object

ca.uhn.fhir.jpa.delete.ThreadSafeResourceDeleterSvc

public class ThreadSafeResourceDeleterSvc
extends Object

Used by CascadingDeleteInterceptor to handle DeleteConflictLists in a thead-safe way.

Specifically, this class spawns an inner transaction for each DeleteConflictList. This class is meant to handle any potential delete collisions (ex ResourceGoneException or ResourceVersionConflictException. In the former case, we swallow the Exception in the inner transaction then continue. In the latter case, we retry according to the RETRY_BACKOFF_PERIOD and RETRY_MAX_ATTEMPTS before giving up.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	RETRY_BACKOFF_PERIOD
static final int	RETRY_MAX_ATTEMPTS

Constructor Summary

Constructors

Constructor	Description
ThreadSafeResourceDeleterSvc(DaoRegistry theDaoRegistry, ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster, IHapiTransactionService theTransactionService)

Method Summary

Modifier and Type	Method	Description
Integer	delete(ca.uhn.fhir.rest.api.server.RequestDetails theRequest, DeleteConflictList theConflictList, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Methods inherited from class java.lang.Object

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

Field Details

RETRY_BACKOFF_PERIOD

public static final long RETRY_BACKOFF_PERIOD

See Also:

• Constant Field Values

RETRY_MAX_ATTEMPTS

public static final int RETRY_MAX_ATTEMPTS

See Also:

• Constant Field Values

Constructor Details

ThreadSafeResourceDeleterSvc

public ThreadSafeResourceDeleterSvc(DaoRegistry theDaoRegistry,
 ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster,
 IHapiTransactionService theTransactionService)

Method Details

delete

public Integer delete(ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 DeleteConflictList theConflictList,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Returns:

number of resources that were successfully deleted