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 and Description
protected AtomicLong	counter
protected static String	NEW_REQUESTS_PATH
protected static String	NEW_REQUESTS_TEMP_PATH

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

bufferLimit, DEFAULT_BUFFER_LIMIT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

FileBasedPersistentProvider

public FileBasedPersistentProvider(String filePath)

FileBasedPersistentProvider

public FileBasedPersistentProvider(long bufferLimit,
                                   String filePath)

Method Detail

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