Interface OutboxConfig


public interface OutboxConfig
Integration point which allows to provide configuration options used by the Outbox implementation.
See Also:
  • Method Details

    • getFetchLimit

      default int getFetchLimit()
      Returns:
      Number of events fetched and processed in a single batch. Defaults to 100.
    • getProcessingDelayWhenAtLeastOneEventWasSuccessfullyProcessed

      default Duration getProcessingDelayWhenAtLeastOneEventWasSuccessfullyProcessed()
      Returns:
      Delay between batches when previous batch successfully processed at least 1 event. Defaults to ZERO.
    • getProcessingDelayWhenNoEvents

      default Duration getProcessingDelayWhenNoEvents()
      Returns:
      Delay between batches when previous batch resulted in zero events. Defaults to 100ms.
    • getProcessingDelayWhenSqlExceptionIsThrown

      default Duration getProcessingDelayWhenSqlExceptionIsThrown()
      Returns:
      Delay between batches when previous batch resulted in SQLException. Defaults to ZERO.
    • getProcessingDelayWhenSqlExceptionIsThrownWhenGettingConnection

      default Duration getProcessingDelayWhenSqlExceptionIsThrownWhenGettingConnection()
      Returns:
      Delay between batches when previous batch resulted in SQLException when getting Connection using {@link ConnectionSource). Defaults to <strong>1s</strong>.
    • getQueueStatsReportingInterval

      default Duration getQueueStatsReportingInterval()
      Returns:
      Queue metrics reporting interval. Defaults to 1s.
    • getSchemaCreationMaxAttempts

      default int getSchemaCreationMaxAttempts()
      When Outbox starts working for the first time some schema changes are required. This method controls how many attempts are made before giving up.
      Returns:
      Number of attempts to create schema needed for the Outbox to store and process the Events. Defaults to 10;