Package com.broadleafcommerce.search.index.core.queue

Class DefaultLocalArrayBlockingDelegatingQueue<T>

java.lang.Object

com.broadleafcommerce.search.index.core.queue.AbstractDelegatingQueue<T>

com.broadleafcommerce.search.index.core.queue.DefaultLocalArrayBlockingDelegatingQueue<T>

Type Parameters:

T - The type of value that this Queue will accept.

All Implemented Interfaces:

Distributable, IndexableTypeAware, ReindexQueue<T>, Iterable<T>, Collection<T>, BlockingQueue<T>, Queue<T>

public class DefaultLocalArrayBlockingDelegatingQueue<T>
extends AbstractDelegatingQueue<T>

Default non-distributed implementation of AbstractDelegatingQueue, backed by an ArrayBlockingQueue.

Author:

Kelly Tisdell (ktisdell)

Constructor Summary

Constructors

Constructor	Description
DefaultLocalArrayBlockingDelegatingQueue(com.broadleafcommerce.search.api.type.IndexableType type, int capacity)

Method Summary

Modifier and Type	Method	Description
final boolean	isDistributed()	Indicates if this component is designed for use across JVMs.

Methods inherited from class com.broadleafcommerce.search.index.core.queue.AbstractDelegatingQueue

add, addAll, clear, contains, containsAll, drainTo, drainTo, element, getDelegate, getIndexableType, getQueueName, isEmpty, isLoaded, iterator, markLoaded, offer, offer, peek, poll, poll, put, remainingCapacity, remove, remove, removeAll, retainAll, size, take, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Details

DefaultLocalArrayBlockingDelegatingQueue

public DefaultLocalArrayBlockingDelegatingQueue(com.broadleafcommerce.search.api.type.IndexableType type,
 int capacity)

Method Details

isDistributed

public final boolean isDistributed()

Description copied from interface: Distributable

Indicates if this component is designed for use across JVMs.

Returns:

whether this component can be distributed across JVMs