Package com.cumulocity.sdk.client.buffering

Class FileBasedPersistentProvider

java.lang.Object

com.cumulocity.sdk.client.buffering.PersistentProvider

com.cumulocity.sdk.client.buffering.FileBasedPersistentProvider

public class FileBasedPersistentProvider
extends PersistentProvider

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicLong	counter
protected static final String	NEW_REQUESTS_PATH
protected static final String	NEW_REQUESTS_TEMP_PATH

Fields inherited from class com.cumulocity.sdk.client.buffering.PersistentProvider

bufferLimit, DEFAULT_BUFFER_LIMIT

Constructor Summary

Constructors

Constructor	Description
FileBasedPersistentProvider(long bufferLimit, String filePath)
FileBasedPersistentProvider(String filePath)

Method Summary

Modifier and Type	Method	Description
long	generateId()
void	offer(ProcessingRequest request)
ProcessingRequest	poll()

Methods inherited from class java.lang.Object

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

Field Details

NEW_REQUESTS_PATH

protected static final String NEW_REQUESTS_PATH

See Also:

• Constant Field Values

NEW_REQUESTS_TEMP_PATH

protected static final String NEW_REQUESTS_TEMP_PATH

See Also:

• Constant Field Values

counter

protected final AtomicLong counter

Constructor Details

FileBasedPersistentProvider

public FileBasedPersistentProvider(String filePath)

FileBasedPersistentProvider

public FileBasedPersistentProvider(long bufferLimit,
 String filePath)

Method Details

generateId

public long generateId()

Specified by:

generateId in class PersistentProvider

offer

public void offer(ProcessingRequest request)

Specified by:

offer in class PersistentProvider

poll

public ProcessingRequest poll()

Specified by:

poll in class PersistentProvider