Package com.github.jonasrutishauser.transactional.event.quarkus

Interface TransactionalEventConfiguration

@ConfigMapping(prefix="quarkus.transactional.event") @ConfigRoot(phase=RUN_TIME) public interface TransactionalEventConfiguration

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    allInUseInterval()
    Time in ms to wait before next dispatching cycle is started if max concurrent dispatching threads are in use.
    int
    initialDispatchInterval()
    Initial seconds to wait before a new check is made for unprocessed events.
    int
    maxAquire()
    Number of unprocessed events to aquire in one transaction.
    int
    maxConcurrentDispatching()
    Max number of events to process concurrently.
    int
    maxDispatchInterval()
    Max seconds to wait before a new check is made for unprocessed events.

  • Method Details

    • allInUseInterval

      @WithDefault("100") int allInUseInterval()
      Time in ms to wait before next dispatching cycle is started if max concurrent dispatching threads are in use.

    • maxDispatchInterval

      @WithDefault("60") int maxDispatchInterval()
      Max seconds to wait before a new check is made for unprocessed events.

    • initialDispatchInterval

      @WithDefault("30") int initialDispatchInterval()
      Initial seconds to wait before a new check is made for unprocessed events.

    • maxAquire

      @WithDefault("10") int maxAquire()
      Number of unprocessed events to aquire in one transaction.

    • maxConcurrentDispatching

      @WithDefault("10") int maxConcurrentDispatching()
      Max number of events to process concurrently.