Package 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	Description
protected boolean	first
protected static final Duration	FIRST_READ_DELAY
protected static final Duration	READ_DELAY
protected final LogTailer<BlobInfoMessage>	tailer

Constructor Summary

Constructors

Constructor	Description
RandomLogBlobInfoFetcher(LogTailer<BlobInfoMessage> blobInfoTailer)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

READ_DELAY

protected static final Duration READ_DELAY

FIRST_READ_DELAY

protected static final Duration FIRST_READ_DELAY

tailer

protected final LogTailer<BlobInfoMessage> tailer

first

protected boolean first

Constructor Details

RandomLogBlobInfoFetcher

public RandomLogBlobInfoFetcher(LogTailer<BlobInfoMessage> blobInfoTailer)

Method Details

get

public BlobInfo get(DocumentMessage.Builder builder)

Specified by:

get in interface BlobInfoFetcher

getDuration

protected Duration getDuration()

close

public void close()

Specified by:

close in interface AutoCloseable