Package org.axonframework.extension.spring.config

Interface EventProcessorSettings.PooledEventProcessorSettings

All Superinterfaces:
EventProcessorSettings
All Known Implementing Classes:
EventProcessorProperties.ProcessorSettings
Enclosing interface:
EventProcessorSettings
public static non-sealed interface EventProcessorSettings.PooledEventProcessorSettings extends EventProcessorSettings
Settings for pooled event processor.

  • Method Details

    • processorMode

      default EventProcessorSettings.ProcessorMode processorMode()
      Retrieves the processor mode.
      Specified by:
      processorMode in interface EventProcessorSettings
      Returns:
      processor mode.

    • initialSegmentCount

      int initialSegmentCount()
      Initial segment count.
      Returns:
      returns initial segment count.

    • tokenClaimIntervalInMillis

      long tokenClaimIntervalInMillis()
      Retrieves token claim interval.
      Returns:
      interval in milliseconds.

    • threadCount

      int threadCount()
      Thread count for pooled processor.
      Returns:
      a positive integer describing the size of the thread pool.

    • batchSize

      int batchSize()
      Batch size for the pooled processor.
      Returns:
      a positive integer describing the size of the batch.

    • claimExtensionThresholdInMillis

      default long claimExtensionThresholdInMillis()
      Threshold, in milliseconds, after which a work package extends the claim on its TrackingToken in the absence of event handling.

      Defaults to 5000 milliseconds, matching the default of the pooled streaming processor configuration.

      Returns:
      the claim extension threshold in milliseconds

    • coordinatorClaimExtension

      default boolean coordinatorClaimExtension()
      Whether the coordinator extends the claims of its work packages, rather than leaving that to the work packages themselves.

      Enable this when event handling regularly takes longer than the claim timeout of the TokenStore: a work package cannot extend its own claim while it is handling a batch, nor while it waits for a thread of the worker executor that lengthy handling on other segments occupies. Defaults to false.

      Returns:
      true if the coordinator extends the claims of its work packages, false otherwise

    • tokenStore

      @Nullable String tokenStore()
      Name of the bean acting as token store for this pooled streaming processor.
      Returns:
      only used if non-null.

    • sequencingPolicy

      default @Nullable String sequencingPolicy()
      Name of the bean acting as the SequencingPolicy this pooled streaming processor applies to its assigned event handling components that do not define a more specific one.

      A SequencingPolicy on an event handler method or class, and a policy given when an event handling component was created manually, take precedence over this policy.

      Defaults to null, in which case no processor-wide policy applies and each assigned event handling component keeps deciding its own sequencing. Without a more specific policy, that is a HierarchicalSequencingPolicy pairing a SequentialPerAggregatePolicy with a SequentialPolicy.

      Returns:
      only used if non-null
      Since:
      5.5.0