Package com.broadleafcommerce.search.index.ignite

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 to IgniteQueue.
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

    Modifier and Type
    Method
    Description
    final 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

    Methods inherited from interface java.lang.Iterable

    forEach

  • Constructor Details

    • IgniteDelegatingQueue

      public IgniteDelegatingQueue(com.broadleafcommerce.search.api.type.IndexableType type, org.apache.ignite.IgniteQueue<T> delegate)

  • Method Details

    • isDistributed

      public final boolean isDistributed()