Package com.broadleafcommerce.dataexchange.service.autoconfigure

Class DataExchangeTaskExecutorProperties

java.lang.Object
com.broadleafcommerce.dataexchange.service.autoconfigure.DataExchangeTaskExecutorProperties
@ConfigurationProperties("broadleaf.dataexchange.async") public class DataExchangeTaskExecutorProperties extends Object
Properties to assist in tuning an AsyncTaskExecutor and RetryTemplate to handle asynchronous tasks that are usually called as part of a synchronous composition.
Author:
Kelly Tisdell (ktisdell)

  • Constructor Details

    • DataExchangeTaskExecutorProperties

      public DataExchangeTaskExecutorProperties()

  • Method Details

    • getTaskExecutorQueueCapacity

      public int getTaskExecutorQueueCapacity()
      The maximum number of future tasks that can be queued. Default is 2000, meaning that 2000 tasks can be queued before the queue starts blocking.
      See Also:

    • getTaskExecutorThreadPoolSize

      public int getTaskExecutorThreadPoolSize()
      The core and maximum number of threads in the thread pool. Note that these threads will mostly be engaged in I/O, specifically making REST API calls or other network calls to other services. Default is 100, meaning that 100 threads will be available to concurrently call other services.
      See Also:

    • getMaxQueueAddTimeMillis

      public long getMaxQueueAddTimeMillis()
      Max time to wait space to become available to schedule a task. This value must be greater than 0. Increasing this value may reduce RejectedExecutionExceptions, but at the cost of blocking threads. Default is 1000 ms.

    • getMaxTries

      public int getMaxTries()
      Maximum tries that should be executed, including initial try and retries. Must be greater than 0. Default is 3.
      See Also:
      • RetryTemplateBuilder.maxAttempts(int)

    • getInitialDelayMillis

      public long getInitialDelayMillis()
      This is used to construct a RetryTemplate and indicates the initial time to wait after an exception is encountered, but before a retry occurs. This value is in milliseconds and must be greater than 0. Default is 10 ms.
      See Also:
      • RetryTemplateBuilder.exponentialBackoff(long, double, long)

    • getDelayMultiplier

      public double getDelayMultiplier()
      This is used to construct a RetryTemplate and indicates a multiplier that is used on the second and subsequent retries. This value is a Double value and must be greater than 1. Default is 2.
      See Also:
      • RetryTemplateBuilder.exponentialBackoff(long, double, long)

    • getMaxDelayMillis

      public long getMaxDelayMillis()
      This is used to construct a RetryTemplate and indicates a multiplier that is used on the second and subsequent retries. This value is in milliseconds and must be greater than getInitialDelayMillis(). Default is 80 ms.
      See Also:

    • setTaskExecutorQueueCapacity

      public void setTaskExecutorQueueCapacity(int taskExecutorQueueCapacity)
      The maximum number of future tasks that can be queued. Default is 2000, meaning that 2000 tasks can be queued before the queue starts blocking.
      See Also:

    • setTaskExecutorThreadPoolSize

      public void setTaskExecutorThreadPoolSize(int taskExecutorThreadPoolSize)
      The core and maximum number of threads in the thread pool. Note that these threads will mostly be engaged in I/O, specifically making REST API calls or other network calls to other services. Default is 100, meaning that 100 threads will be available to concurrently call other services.
      See Also:

    • setMaxQueueAddTimeMillis

      public void setMaxQueueAddTimeMillis(long maxQueueAddTimeMillis)
      Max time to wait space to become available to schedule a task. This value must be greater than 0. Increasing this value may reduce RejectedExecutionExceptions, but at the cost of blocking threads. Default is 1000 ms.

    • setMaxTries

      public void setMaxTries(int maxTries)
      Maximum tries that should be executed, including initial try and retries. Must be greater than 0. Default is 3.
      See Also:
      • RetryTemplateBuilder.maxAttempts(int)

    • setInitialDelayMillis

      public void setInitialDelayMillis(long initialDelayMillis)
      This is used to construct a RetryTemplate and indicates the initial time to wait after an exception is encountered, but before a retry occurs. This value is in milliseconds and must be greater than 0. Default is 10 ms.
      See Also:
      • RetryTemplateBuilder.exponentialBackoff(long, double, long)

    • setDelayMultiplier

      public void setDelayMultiplier(double delayMultiplier)
      This is used to construct a RetryTemplate and indicates a multiplier that is used on the second and subsequent retries. This value is a Double value and must be greater than 1. Default is 2.
      See Also:
      • RetryTemplateBuilder.exponentialBackoff(long, double, long)

    • setMaxDelayMillis

      public void setMaxDelayMillis(long maxDelayMillis)
      This is used to construct a RetryTemplate and indicates a multiplier that is used on the second and subsequent retries. This value is in milliseconds and must be greater than getInitialDelayMillis(). Default is 80 ms.
      See Also:

    • 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