com.google.enterprise.connector.util.diffing

Class CheckpointAndChangeQueue

java.lang.Object

com.google.enterprise.connector.util.diffing.CheckpointAndChangeQueue

public class CheckpointAndChangeQueue
extends java.lang.Object

Queue of CheckpointAndChange objects to be processed by the DiffingConnectorTraversalManager. Objects are added to the queue from a ChangeSource and assigned a DiffingConnectorCheckpoint. The client accesses objects by calling resume(String). To facilitate retry of processing for objects in the queue CheckpointAndChange objects remain until the client indicates they have completed processing by calling resume(String) with the object's checkpoint or a later object's checkpoint.

Since:

2.8

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAXIMUM_QUEUE_SIZE

Constructor Summary

Constructors

Constructor and Description
CheckpointAndChangeQueue(ChangeSource changeSource, java.io.File persistDir, DocumentHandleFactory internalDocumentHandleFactory, DocumentHandleFactory clientDocumentHandleFactory)

Method Summary

Modifier and Type	Method and Description
void	setMaximumQueueSize(int maximumQueueSize)
void	start(java.lang.String checkpointString) Initialize to start processing from after the passed in checkpoint or from the beginning if the passed in checkpoint is null.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAXIMUM_QUEUE_SIZE

public static final int DEFAULT_MAXIMUM_QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

CheckpointAndChangeQueue

public CheckpointAndChangeQueue(ChangeSource changeSource,
                                java.io.File persistDir,
                                DocumentHandleFactory internalDocumentHandleFactory,
                                DocumentHandleFactory clientDocumentHandleFactory)

Method Detail

start

public void start(java.lang.String checkpointString)
           throws java.io.IOException

Initialize to start processing from after the passed in checkpoint or from the beginning if the passed in checkpoint is null. Part of making DocumentSnapshotRepositoryMonitorManager go from "cold" to "warm".

Throws:

java.io.IOException

setMaximumQueueSize

public void setMaximumQueueSize(int maximumQueueSize)