Package com.broadleafcommerce.search.index.autoconfigure

Class IndexerProperties.QueueProperties

java.lang.Object
com.broadleafcommerce.search.index.autoconfigure.IndexerProperties.QueueProperties
Enclosing class:
IndexerProperties
public static class IndexerProperties.QueueProperties extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    QueueProperties()
     

  • Method Summary

    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()
     

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • QueueProperties

      public QueueProperties()

  • Method Details

    • 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

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object