Class IgniteDelegatingQueue<T>
- java.lang.Object
-
- com.broadleafcommerce.search.index.core.queue.AbstractDelegatingQueue<T>
-
- com.broadleafcommerce.search.index.ignite.IgniteDelegatingQueue<T>
-
- Type Parameters:
T
- The type of item that this Queue will hold.
- All Implemented Interfaces:
com.broadleafcommerce.search.index.core.Distributable
,com.broadleafcommerce.search.index.core.IndexableTypeAware
,com.broadleafcommerce.search.index.core.queue.ReindexQueue<T>
,Iterable<T>
,Collection<T>
,BlockingQueue<T>
,Queue<T>
public class IgniteDelegatingQueue<T> extends com.broadleafcommerce.search.index.core.queue.AbstractDelegatingQueue<T>
BlockingQueue
implementation that delegates toIgniteQueue
.- Author:
- Kelly Tisdell (ktisdell)
-
-
Constructor Summary
Constructors Constructor Description IgniteDelegatingQueue(com.broadleafcommerce.search.api.type.IndexableType type, org.apache.ignite.IgniteQueue<T> delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isDistributed()
-
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
-
-
-
-
Constructor Detail
-
IgniteDelegatingQueue
public IgniteDelegatingQueue(com.broadleafcommerce.search.api.type.IndexableType type, org.apache.ignite.IgniteQueue<T> delegate)
-
-