Package com.avoka.fc.core.inbox

Class AbstractInboxProcessor

java.lang.Object
com.avoka.fc.core.inbox.AbstractInboxProcessor
All Implemented Interfaces:
IInboxProcessor, IServiceDefinitionAware
Direct Known Subclasses:
RestInboxProcessor
public abstract class AbstractInboxProcessor extends Object implements IInboxProcessor, IServiceDefinitionAware
Provide an inbox processor to process inbox events.
Since:
24.4.0

  • Constructor Details

    • AbstractInboxProcessor

      public AbstractInboxProcessor()

  • Method Details

    • getFetchLimit

      public int getFetchLimit()
      Return the fetch limit to limit the maximum number of events need to be processed.
      Returns:
      the fetch limit to limit the maximum number of events need to be processed

    • setFetchLimit

      public void setFetchLimit(int fetchLimit)
      Set the fetch limit to limit the maximum number of events need to be processed.
      Parameters:
      fetchLimit - the fetch limit to limit the maximum number of events need to be processed

    • getMaxRetry

      public int getMaxRetry()
      Return the number of retry to process an event it failed.
      Returns:
      the number of retry to process an event it failed

    • setMaxRetry

      public void setMaxRetry(int maxRetry)
      Set the number of retry to process an event it failed.
      Parameters:
      maxRetry - the number of retry to process an event it failed

    • getWaitForQueueTimeout

      public int getWaitForQueueTimeout()
      Return how long to wait for adding in processing event queue (in milliseconds)
      Returns:
      the timeout for adding in processing event queue (in milliseconds)

    • setWaitForQueueTimeout

      public void setWaitForQueueTimeout(int waitForQueueTimeout)
      Set how long to wait for adding in processing event queue (in milliseconds).
      Parameters:
      waitForQueueTimeout - the timeout for adding in processing event queue (in milliseconds)

    • getQueueTimeout

      public int getQueueTimeout()
      Return how long to wait in event queue to process (in minutes).
      Returns:
      the timeout to wait in event queue to process

    • setQueueTimeout

      public void setQueueTimeout(int queueTimeout)
      Set how long to wait in event queue to process (in minutes).
      Parameters:
      queueTimeout - the timeout to wait in event queue to process

    • getInProgressTimeout

      public int getInProgressTimeout()
      Return how long to wait to process (in minutes).
      Returns:
      the timeout to wait to process

    • setInProgressTimeout

      public void setInProgressTimeout(int inProgressTimeout)
      set how long to wait to process (in minutes).
      Parameters:
      inProgressTimeout - the timeout to wait to process

    • getServiceDefinition

      public ServiceDefinition getServiceDefinition()
      Return the service definition for the service.
      Specified by:
      getServiceDefinition in interface IServiceDefinitionAware
      Returns:
      the service definition for the service.

    • setServiceDefinition

      public void setServiceDefinition(ServiceDefinition serviceDefinition)
      Set the service definition for the service.
      Specified by:
      setServiceDefinition in interface IServiceDefinitionAware
      Parameters:
      serviceDefinition - the service definition for the service.