de.hybris.platform.ycommercewebservices.queues.impl

Class AbstractUpdateQueue<T>

java.lang.Object

java.util.AbstractMap<K,V>

java.util.TreeMap<java.lang.Long,T>

de.hybris.platform.ycommercewebservices.queues.impl.AbstractUpdateQueue<T>

All Implemented Interfaces:

UpdateQueue<T>, java.io.Serializable, java.lang.Cloneable, java.util.Map<java.lang.Long,T>, java.util.NavigableMap<java.lang.Long,T>, java.util.SortedMap<java.lang.Long,T>

Direct Known Subclasses:

OrderStatusUpdateQueue, ProductExpressUpdateQueue

public abstract class AbstractUpdateQueue<T>
extends java.util.TreeMap<java.lang.Long,T>
implements UpdateQueue<T>

Abstract implementation of UpdateQueue using TreeMap for storing elements WARNING: this queue has limited capacity due to its in-memory nature

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

java.util.AbstractMap.SimpleEntry<K,V>, java.util.AbstractMap.SimpleImmutableEntry<K,V>

Constructor Summary

Constructors

Constructor and Description
AbstractUpdateQueue()

Method Summary

Modifier and Type	Method and Description
void	addItem(T item) Adds item to the queue
void	addItems(java.util.List<T> items) Adds all elements from the list to the queue
java.util.List<T>	getItems() Returns all elements in the queue.
java.util.List<T>	getItems(java.util.Date newerThan) Returns all elements in the queue newer than a specific day
T	getLastItem() Returns last item from the queue
int	getMaxCapacity()
protected java.lang.Long	getTimeKey(T item)
void	removeItems() Removes all elements from the queue
void	removeItems(<any> predicate) Removes all elements from the queue older than a specific date
void	removeItems(java.util.Date olderThan) Removes all elements from the queue older than a specific date
void	setMaxCapacity(int maxCapacity)

Methods inherited from class java.util.TreeMap

ceilingEntry, ceilingKey, clear, clone, comparator, containsKey, containsValue, descendingKeySet, descendingMap, entrySet, firstEntry, firstKey, floorEntry, floorKey, forEach, get, headMap, headMap, higherEntry, higherKey, keySet, lastEntry, lastKey, lowerEntry, lowerKey, navigableKeySet, pollFirstEntry, pollLastEntry, put, putAll, remove, replace, replace, replaceAll, size, subMap, subMap, tailMap, tailMap, values

Methods inherited from class java.util.AbstractMap

equals, hashCode, isEmpty, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, getOrDefault, hashCode, isEmpty, merge, putIfAbsent, remove

Constructor Detail

AbstractUpdateQueue

public AbstractUpdateQueue()

Method Detail

getItems

public java.util.List<T> getItems()

Description copied from interface: UpdateQueue

Returns all elements in the queue.

Specified by:

getItems in interface UpdateQueue<T>

Returns:

list of stored elements

getItems

public java.util.List<T> getItems(java.util.Date newerThan)

Description copied from interface: UpdateQueue

Returns all elements in the queue newer than a specific day

Specified by:

getItems in interface UpdateQueue<T>

Parameters:

newerThan - threshold date

Returns:

list of stored elements

addItem

public void addItem(T item)

Description copied from interface: UpdateQueue

Adds item to the queue

Specified by:

addItem in interface UpdateQueue<T>

Parameters:

item - elements to be stored

addItems

public void addItems(java.util.List<T> items)

Description copied from interface: UpdateQueue

Adds all elements from the list to the queue

Specified by:

addItems in interface UpdateQueue<T>

Parameters:

items - elements to be stored

removeItems

public void removeItems(java.util.Date olderThan)

Description copied from interface: UpdateQueue

Removes all elements from the queue older than a specific date

Specified by:

removeItems in interface UpdateQueue<T>

Parameters:

olderThan - threshold date

removeItems

public void removeItems()

Description copied from interface: UpdateQueue

Removes all elements from the queue

Specified by:

removeItems in interface UpdateQueue<T>

removeItems

public void removeItems(<any> predicate)

Description copied from interface: UpdateQueue

Removes all elements from the queue older than a specific date

Specified by:

removeItems in interface UpdateQueue<T>

Parameters:

predicate - threshold date

getLastItem

public T getLastItem()

Description copied from interface: UpdateQueue

Returns last item from the queue

Specified by:

getLastItem in interface UpdateQueue<T>

Returns:

last element

getMaxCapacity

public int getMaxCapacity()

setMaxCapacity

public void setMaxCapacity(int maxCapacity)

getTimeKey

protected java.lang.Long getTimeKey(T item)