reactor.io.queue

Class InMemoryQueuePersistor<T>

java.lang.Object

reactor.io.queue.InMemoryQueuePersistor<T>

All Implemented Interfaces:

Iterable<T>, QueuePersistor<T>

public class InMemoryQueuePersistor<T>
extends Object
implements QueuePersistor<T>

A QueuePersistor implementations that stores items in-memory.

Author:

Jon Brisbin, Stephane Maldini

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.
T	get(Long idx) Return the item with the given id.
boolean	hasNext() Are there more items waiting to be returned?
Iterator<T>	iterator()
long	lastId() Get the value of the last item to have been persisted.
Long	offer(T obj) Persist and return the last Long id of the item.
Long	offerAll(Collection<T> t) Persist N items in batch and return a Long id of the last item.
Map<Long,T>	refMap()
T	remove() 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 Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

offer

public Long offer(@Nonnull
                  T obj)

Description copied from interface: QueuePersistor

Persist and return the last Long id of the item.

Specified by:

offer in interface QueuePersistor<T>

Parameters:

obj - element to persist

Returns:

id of the item just persisted

offerAll

public Long offerAll(@Nonnull
                     Collection<T> t)

Description copied from interface: QueuePersistor

Persist N items in batch and return a Long id of the last item.

Specified by:

offerAll in interface QueuePersistor<T>

Parameters:

t - element to persist

Returns:

id of the item just persisted

get

public T get(Long idx)

Description copied from interface: QueuePersistor

Return the item with the given id.

Specified by:

get in interface QueuePersistor<T>

Parameters:

idx - the given index to lookup

Returns:

item persisted under the given id

remove

public T remove()

Description copied from interface: QueuePersistor

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>

refMap

public Map<Long,T> refMap()