Package com.broadleafcommerce.search.index.ignite

Class 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

      All Methods Instance Methods Concrete Methods 
      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)  
      boolean isDistributed()  

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

        destroyQueue, getOrCreateQueue, getQueueRegistry, getQueueSize

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

        destroyQueue, getOrCreateQueue

    • Constructor Detail

      • IgniteQueueProvider

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

    • Method Detail

      • 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