reactor.queue

Interface QueuePersistor<T>

All Superinterfaces:

java.lang.Iterable<T>

All Known Implementing Classes:

IndexedChronicleQueuePersistor, InMemoryQueuePersistor

public interface QueuePersistor<T>
extends java.lang.Iterable<T>

Implementations of this interface are responsible for persisting the elements of a PersistentQueue. Persistence could be achieved through in-memory solutions like a Map or could be more complex and use a backing datastore.

Method Summary

Modifier and Type	Method and Description
void	close() Release any internal resources used by the persistence mechanism.
Function<java.lang.Long,T>	get() Returns a Function that will return the item with the given id.
boolean	hasNext() Are there more items waiting to be returned?
long	lastId() Get the value of the last item to have been persisted.
Function<T,java.lang.Long>	offer() Returns a Function that will persist the item and return a Long id for the item.
Supplier<T>	remove() Returns a Supplier that will simply remove the oldest item from the persistence queue.
long	size() Get the number of items persisted right now.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Detail

lastId

long lastId()

Get the value of the last item to have been persisted.

Returns:

last ID persisted

size

long size()

Get the number of items persisted right now.

Returns:

number of items persisted

hasNext

boolean hasNext()

Are there more items waiting to be returned?

Returns:

true if items can be retrieved from this persistor, false otherwise

offer

@Nonnull
Function<T,java.lang.Long> offer()

Returns a Function that will persist the item and return a Long id for the item.

Returns:

id of the item just persisted

get

@Nonnull
Function<java.lang.Long,T> get()

Returns a Function that will return the item with the given id.

Returns:

item persisted under the given id

remove

@Nonnull
Supplier<T> remove()

Returns a Supplier that will simply remove the oldest item from the persistence queue.

Returns:

the oldest item in the queue

close

void close()

Release any internal resources used by the persistence mechanism.