Package com.broadleafcommerce.search.index.ignite

Class IgniteQueueProvider

java.lang.Object
com.broadleafcommerce.search.index.core.queue.AbstractQueueProvider
com.broadleafcommerce.search.index.ignite.IgniteQueueProvider
All Implemented Interfaces:
com.broadleafcommerce.search.index.core.Distributable, com.broadleafcommerce.search.index.core.queue.QueueProvider
public class IgniteQueueProvider extends com.broadleafcommerce.search.index.core.queue.AbstractQueueProvider implements com.broadleafcommerce.search.index.core.queue.QueueProvider
This QueueProvider returns instances of IgniteQueue, which are distributable within the Ignite cluster.
Author:
Kelly Tisdell (ktisdell)

  • Constructor Summary

    Constructors
    Constructor
    Description
    IgniteQueueProvider(org.apache.ignite.Ignite ignite, org.apache.ignite.configuration.CollectionConfiguration collectionConfiguration, com.broadleafcommerce.search.index.core.ProcessStateService processStateService, int defaultMaxQueueSize)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected <T> com.broadleafcommerce.search.index.core.queue.ReindexQueue<T>
    createQueue(com.broadleafcommerce.search.api.type.IndexableType type)
     
    protected void
    destroyQueueInternal(com.broadleafcommerce.search.index.core.queue.ReindexQueue<?> queue)
     
    final boolean
    isDistributed()
     

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

    destroyQueue, getOrCreateQueue, getQueueRegistry, getQueueSize

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface com.broadleafcommerce.search.index.core.queue.QueueProvider

    destroyQueue, getOrCreateQueue

  • Constructor Details

    • IgniteQueueProvider

      public IgniteQueueProvider(org.apache.ignite.Ignite ignite, org.apache.ignite.configuration.CollectionConfiguration collectionConfiguration, com.broadleafcommerce.search.index.core.ProcessStateService processStateService, int defaultMaxQueueSize)

  • Method Details

    • createQueue

      protected <T> com.broadleafcommerce.search.index.core.queue.ReindexQueue<T> createQueue(com.broadleafcommerce.search.api.type.IndexableType type)
      Specified by:
      createQueue in class com.broadleafcommerce.search.index.core.queue.AbstractQueueProvider

    • destroyQueueInternal

      protected void destroyQueueInternal(com.broadleafcommerce.search.index.core.queue.ReindexQueue<?> queue)
      Specified by:
      destroyQueueInternal in class com.broadleafcommerce.search.index.core.queue.AbstractQueueProvider

    • isDistributed

      public final boolean isDistributed()
      Specified by:
      isDistributed in interface com.broadleafcommerce.search.index.core.Distributable