reactor.queue

Class InMemoryQueuePersistor<T>

java.lang.Object

reactor.queue.InMemoryQueuePersistor<T>

All Implemented Interfaces:

java.lang.Iterable<T>, QueuePersistor<T>

public class InMemoryQueuePersistor<T>
extends java.lang.Object
implements QueuePersistor<T>

A QueuePersistor implementations that stores items in-memory.

Constructor Summary

Constructors

Constructor and Description
InMemoryQueuePersistor()

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?
java.util.Iterator<T>	iterator()
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 class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

InMemoryQueuePersistor

public InMemoryQueuePersistor()

Method Detail

lastId

public long lastId()

Description copied from interface: QueuePersistor

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

Specified by:

lastId in interface QueuePersistor<T>

Returns:

last ID persisted

size

public long size()

Description copied from interface: QueuePersistor

Get the number of items persisted right now.

Specified by:

size in interface QueuePersistor<T>

Returns:

number of items persisted

hasNext

public boolean hasNext()

Description copied from interface: QueuePersistor

Are there more items waiting to be returned?

Specified by:

hasNext in interface QueuePersistor<T>

Returns:

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

iterator

public java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

offer

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

Description copied from interface: QueuePersistor

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

Specified by:

offer in interface QueuePersistor<T>

Returns:

id of the item just persisted

get

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

Description copied from interface: QueuePersistor

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

Specified by:

get in interface QueuePersistor<T>

Returns:

item persisted under the given id

remove

@Nonnull
public Supplier<T> remove()

Description copied from interface: QueuePersistor

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

Specified by:

remove in interface QueuePersistor<T>

Returns:

the oldest item in the queue

close

public void close()

Description copied from interface: QueuePersistor

Release any internal resources used by the persistence mechanism.

Specified by:

close in interface QueuePersistor<T>