reactor.queue

Class IndexedChronicleQueuePersistor<T>

java.lang.Object

reactor.queue.IndexedChronicleQueuePersistor<T>

All Implemented Interfaces:

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

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

A QueuePersistor implementation that uses a Java Chronicle IndexedChronicle to persist items in the queue.

See Also:

Java Chronicle

Constructor Summary

Constructors

Constructor and Description
IndexedChronicleQueuePersistor(java.lang.String basePath) Create an IndexedChronicleQueuePersistor based on the given base path.
IndexedChronicleQueuePersistor(java.lang.String basePath, Codec<Buffer,T,T> codec, boolean clearOnStart, boolean deleteOnExit, net.openhft.chronicle.ChronicleConfig config) Create an IndexedChronicleQueuePersistor based on the given base path, encoder and decoder.

Method Summary

Modifier and Type	Method and Description
void	close() Close the underlying chronicles.
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

IndexedChronicleQueuePersistor

public IndexedChronicleQueuePersistor(@Nonnull
                                      java.lang.String basePath)
                               throws java.io.IOException

Create an IndexedChronicleQueuePersistor based on the given base path.

Parameters:

basePath - Directory in which to create the Chronicle.

Throws:

java.io.IOException

IndexedChronicleQueuePersistor

public IndexedChronicleQueuePersistor(@Nonnull
                                      java.lang.String basePath,
                                      @Nonnull
                                      Codec<Buffer,T,T> codec,
                                      boolean clearOnStart,
                                      boolean deleteOnExit,
                                      @Nonnull
                                      net.openhft.chronicle.ChronicleConfig config)
                               throws java.io.IOException

Create an IndexedChronicleQueuePersistor based on the given base path, encoder and decoder. Optionally, passing false to clearOnStart skips clearing the Chronicle on start for appending.

Parameters:

basePath - Directory in which to create the Chronicle.

codec - Codec to turn objects into Buffers and visa-versa.

clearOnStart - Whether or not to clear the Chronicle on start.

deleteOnExit - Whether or not to delete the Chronicle when the program exits.

config - ChronicleConfig to use.

Throws:

java.io.IOException

Method Detail

close

public void close()

Close the underlying chronicles.

Specified by:

close in interface QueuePersistor<T>

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

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

iterator

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

Specified by:

iterator in interface java.lang.Iterable<T>