org.nuxeo.importer.stream.producer

Class RandomLogBlobInfoFetcher

java.lang.Object

org.nuxeo.importer.stream.producer.RandomLogBlobInfoFetcher

All Implemented Interfaces:

AutoCloseable, BlobInfoFetcher

public class RandomLogBlobInfoFetcher
extends Object
implements BlobInfoFetcher

Returns blob information from a Log, loop on the log.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	first
protected static int	READ_DELAY_MS
protected LogTailer<BlobInfoMessage>	tailer

Constructor Summary

Constructors

Constructor and Description
RandomLogBlobInfoFetcher(LogTailer<BlobInfoMessage> blobInfoTailer)

Method Summary

Modifier and Type	Method and Description
void	close()
BlobInfo	get(DocumentMessage.Builder builder)

Methods inherited from class java.lang.Object

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

Field Detail

READ_DELAY_MS

protected static final int READ_DELAY_MS

See Also:

Constant Field Values

tailer

protected final LogTailer<BlobInfoMessage> tailer

first

protected boolean first

Constructor Detail

RandomLogBlobInfoFetcher

public RandomLogBlobInfoFetcher(LogTailer<BlobInfoMessage> blobInfoTailer)

Method Detail

get

public BlobInfo get(DocumentMessage.Builder builder)

Specified by:

get in interface BlobInfoFetcher

close

public void close()

Specified by:

close in interface AutoCloseable