Package com.broadleafcommerce.search.index.autoconfigure

Class IndexerProperties.QueueProperties

    • Constructor Summary

      Constructors 
      Constructor Description
      QueueProperties()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected boolean canEqual​(Object other)  
      boolean equals​(Object o)  
      int getLoadMaxTries()
      Defines the number of times that we'll try to put something from a bounded BlockingQueue with the given wait time before giving up, for example when nothing is reading from the Queue.
      long getLoadWaitTime()
      Time in milliseconds to wait put something on a bounded BlockingQueue.
      int getMaxQueueSize()
      The maximum allowed size of the queue.
      int getReadMaxTries()
      Defines the number of times that we'll try to retrieve something from a queue with the given wait time before giving up.
      long getReadWaitTime()
      Time in milliseconds to wait for something to arrive in the Queue.
      int hashCode()  
      void setLoadMaxTries​(int loadMaxTries)
      Defines the number of times that we'll try to put something from a bounded BlockingQueue with the given wait time before giving up, for example when nothing is reading from the Queue.
      void setLoadWaitTime​(long loadWaitTime)
      Time in milliseconds to wait put something on a bounded BlockingQueue.
      void setMaxQueueSize​(int maxQueueSize)
      The maximum allowed size of the queue.
      void setReadMaxTries​(int readMaxTries)
      Defines the number of times that we'll try to retrieve something from a queue with the given wait time before giving up.
      void setReadWaitTime​(long readWaitTime)
      Time in milliseconds to wait for something to arrive in the Queue.
      String toString()  

    • Constructor Detail

      • QueueProperties

        public QueueProperties()

    • Method Detail

      • getLoadWaitTime

        public long getLoadWaitTime()
        Time in milliseconds to wait put something on a bounded BlockingQueue. Keep this rather small. We want to wait and try again to ensure that we don't block indefinitely and to check that there was not a failure while we began waiting.
        Returns:
        time to wait while putting onto the queue

      • getLoadMaxTries

        public int getLoadMaxTries()
        Defines the number of times that we'll try to put something from a bounded BlockingQueue with the given wait time before giving up, for example when nothing is reading from the Queue.
        Returns:
        number of times to try putting an object onto the queue

      • getMaxQueueSize

        public int getMaxQueueSize()
        The maximum allowed size of the queue.
        Returns:
        maximum allowed size of the queue

      • getReadWaitTime

        public long getReadWaitTime()
        Time in milliseconds to wait for something to arrive in the Queue. Keep this rather small.
        Returns:
        time to wait for something to arrive in the queue

      • getReadMaxTries

        public int getReadMaxTries()
        Defines the number of times that we'll try to retrieve something from a queue with the given wait time before giving up. Either nothing is putting data on the queue, or the cluster size is too big and we're just not receiving data because other threads are consuming the data fast enough that we never receive any.
        Returns:
        number of times to try to retrieve something from the queue

      • setLoadWaitTime

        public void setLoadWaitTime​(long loadWaitTime)
        Time in milliseconds to wait put something on a bounded BlockingQueue. Keep this rather small. We want to wait and try again to ensure that we don't block indefinitely and to check that there was not a failure while we began waiting.
        Parameters:
        loadWaitTime - time to wait while putting onto the queue

      • setLoadMaxTries

        public void setLoadMaxTries​(int loadMaxTries)
        Defines the number of times that we'll try to put something from a bounded BlockingQueue with the given wait time before giving up, for example when nothing is reading from the Queue.
        Parameters:
        loadMaxTries - number of times to try putting an object onto the queue

      • setMaxQueueSize

        public void setMaxQueueSize​(int maxQueueSize)
        The maximum allowed size of the queue.
        Parameters:
        maxQueueSize - maximum allowed size of the queue

      • setReadWaitTime

        public void setReadWaitTime​(long readWaitTime)
        Time in milliseconds to wait for something to arrive in the Queue. Keep this rather small.
        Parameters:
        readWaitTime - time to wait for something to arrive in the queue

      • setReadMaxTries

        public void setReadMaxTries​(int readMaxTries)
        Defines the number of times that we'll try to retrieve something from a queue with the given wait time before giving up. Either nothing is putting data on the queue, or the cluster size is too big and we're just not receiving data because other threads are consuming the data fast enough that we never receive any.
        Parameters:
        readMaxTries - number of times to try to retrieve something from the queue

      • canEqual

        protected boolean canEqual​(Object other)

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object