Package io.axoniq.framework.springboot

Class WorkflowProperties.HistoryProcessorProperties

java.lang.Object
io.axoniq.framework.springboot.WorkflowProperties.HistoryProcessorProperties
Enclosing class:
WorkflowProperties
public static class WorkflowProperties.HistoryProcessorProperties extends Object
The properties of the history projector's own, dedicated event processor.

Mirrors the same settings WorkflowProperties exposes for the workflow engine's own processor - see there for what each property means and what it defaults to.

  • Constructor Summary

    Constructors
    Constructor
    Description
    HistoryProcessorProperties()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    getBatchSize()
    Returns the maximum number of events read from the event store per source poll.
    long
    getClaimExtensionThreshold()
    Returns the duration, in milliseconds, after which the history processor extends a segment claim.
    boolean
    getCoordinatorClaimExtension()
    Returns whether the history processor's coordinator also extends segment claims.
    int
    getInitialSegmentCount()
    Returns the number of segments to initialize the history projector's event processor with.
    int
    getThreadCount()
    Returns the number of threads the history processor uses to process events concurrently.
    long
    getTokenClaimInterval()
    Returns the interval, in milliseconds, at which the history processor's coordinator attempts to claim unclaimed segments.
    void
    setBatchSize(int batchSize)
    Sets the maximum number of events read from the event store per source poll.
    void
    setClaimExtensionThreshold(long claimExtensionThreshold)
    Sets the duration, in milliseconds, after which the history processor extends a segment claim.
    void
    setCoordinatorClaimExtension(boolean coordinatorClaimExtension)
    Sets whether the history processor's coordinator also extends segment claims.
    void
    setInitialSegmentCount(int initialSegmentCount)
    Sets the number of segments to initialize the history projector's event processor with.
    void
    setThreadCount(int threadCount)
    Sets the number of threads the history processor uses to process events concurrently.
    void
    setTokenClaimInterval(long tokenClaimInterval)
    Sets the interval, in milliseconds, at which the history processor's coordinator attempts to claim unclaimed segments.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • HistoryProcessorProperties

      public HistoryProcessorProperties()

  • Method Details

    • getInitialSegmentCount

      public int getInitialSegmentCount()
      Returns the number of segments to initialize the history projector's event processor with.
      Returns:
      the number of segments to initialize the history projector's event processor with

    • setInitialSegmentCount

      public void setInitialSegmentCount(int initialSegmentCount)
      Sets the number of segments to initialize the history projector's event processor with.
      Parameters:
      initialSegmentCount - the number of segments to initialize the history projector's event processor with

    • getBatchSize

      public int getBatchSize()
      Returns the maximum number of events read from the event store per source poll.
      Returns:
      the maximum number of events read from the event store per source poll

    • setBatchSize

      public void setBatchSize(int batchSize)
      Sets the maximum number of events read from the event store per source poll.
      Parameters:
      batchSize - the maximum number of events read from the event store per source poll

    • getThreadCount

      public int getThreadCount()
      Returns the number of threads the history processor uses to process events concurrently.
      Returns:
      the number of threads the history processor uses to process events concurrently

    • setThreadCount

      public void setThreadCount(int threadCount)
      Sets the number of threads the history processor uses to process events concurrently.
      Parameters:
      threadCount - the number of threads the history processor uses to process events concurrently

    • getTokenClaimInterval

      public long getTokenClaimInterval()
      Returns the interval, in milliseconds, at which the history processor's coordinator attempts to claim unclaimed segments.
      Returns:
      the segment-claim interval, in milliseconds

    • setTokenClaimInterval

      public void setTokenClaimInterval(long tokenClaimInterval)
      Sets the interval, in milliseconds, at which the history processor's coordinator attempts to claim unclaimed segments.
      Parameters:
      tokenClaimInterval - the segment-claim interval, in milliseconds

    • getClaimExtensionThreshold

      public long getClaimExtensionThreshold()
      Returns the duration, in milliseconds, after which the history processor extends a segment claim.
      Returns:
      the claim extension threshold, in milliseconds

    • setClaimExtensionThreshold

      public void setClaimExtensionThreshold(long claimExtensionThreshold)
      Sets the duration, in milliseconds, after which the history processor extends a segment claim.
      Parameters:
      claimExtensionThreshold - the claim extension threshold, in milliseconds

    • getCoordinatorClaimExtension

      public boolean getCoordinatorClaimExtension()
      Returns whether the history processor's coordinator also extends segment claims.
      Returns:
      whether the history processor's coordinator also extends segment claims

    • setCoordinatorClaimExtension

      public void setCoordinatorClaimExtension(boolean coordinatorClaimExtension)
      Sets whether the history processor's coordinator also extends segment claims.
      Parameters:
      coordinatorClaimExtension - whether the history processor's coordinator also extends segment claims