Class ServerDrivenReindexOperation


  • public class ServerDrivenReindexOperation
    extends DriveReindexOperation
    Drives the $reindex custom operation in parallel. Each thread keeps running until the OperationOutcome indicates that no work remains to be processed.
    • Constructor Detail

      • ServerDrivenReindexOperation

        public ServerDrivenReindexOperation​(FHIRBucketClient fhirClient,
                                            int maxConcurrentRequests,
                                            String tstampParam,
                                            int resourceCountParam)
        Public constructor
        Parameters:
        client - the FHIR client
        maxConcurrentRequests - the number of threads to spin up
    • Method Detail

      • monitorLoop

        public void monitorLoop()
        The main monitor loop.
      • safeSleep

        protected void safeSleep​(long ms)
        Sleep for the given number of ms, or until interrupted
        Overrides:
        safeSleep in class DriveReindexOperation
        Parameters:
        ms -
      • signalStop

        public void signalStop()
        Program is stopping, so tell the threads they can stop too
        Specified by:
        signalStop in class DriveReindexOperation