Package ca.uhn.fhir.jpa.subscription.async

Class AsyncResourceModifiedSubmitterSvc

java.lang.Object

ca.uhn.fhir.jpa.subscription.async.AsyncResourceModifiedSubmitterSvc

public class AsyncResourceModifiedSubmitterSvc
extends Object

The purpose of this service is to submit messages to the processing pipeline for which previous attempts at submission has failed. See also AsyncResourceModifiedProcessingSchedulerSvc and IResourceModifiedMessagePersistenceSvc.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_LIMIT

Constructor Summary

Constructors

Constructor	Description
AsyncResourceModifiedSubmitterSvc(IResourceModifiedMessagePersistenceSvc theResourceModifiedMessagePersistenceSvc, IResourceModifiedConsumerWithRetries theResourceModifiedConsumer)

Method Summary

Modifier and Type	Method	Description
static int	getLimit()
void	runDeliveryPass()

Methods inherited from class java.lang.Object

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

Field Details

MAX_LIMIT

public static final int MAX_LIMIT

See Also:

• Constant Field Values

Constructor Details

AsyncResourceModifiedSubmitterSvc

public AsyncResourceModifiedSubmitterSvc(IResourceModifiedMessagePersistenceSvc theResourceModifiedMessagePersistenceSvc,
 IResourceModifiedConsumerWithRetries theResourceModifiedConsumer)

Method Details

runDeliveryPass

public void runDeliveryPass()

getLimit

public static int getLimit()