Package com.ibm.fhir.bucket.reindex

Class ServerDrivenReindexOperation

java.lang.Object

com.ibm.fhir.bucket.reindex.DriveReindexOperation

com.ibm.fhir.bucket.reindex.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 Summary

Constructors

Constructor	Description
ServerDrivenReindexOperation(FHIRBucketClient fhirClient, int maxConcurrentRequests, String tstampParam, int resourceCountParam)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	init()	Start the main loop
void	monitorLoop()	The main monitor loop.
void	signalStop()	Program is stopping, so tell the threads they can stop too
void	waitForStop()	Wait until things are stopped

Methods inherited from class com.ibm.fhir.bucket.reindex.DriveReindexOperation

intValue, str

Methods inherited from class java.lang.Object

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

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

init

public void init()

Start the main loop

Specified by:

init in class DriveReindexOperation

monitorLoop

public void monitorLoop()

The main monitor loop.

signalStop

public void signalStop()

Program is stopping, so tell the threads they can stop too

Specified by:

signalStop in class DriveReindexOperation

waitForStop

public void waitForStop()

Wait until things are stopped

Specified by:

waitForStop in class DriveReindexOperation