scheduler

abstract val scheduler: Scheduler

The scheduler to use for processing message exchanges.

The scheduler determines the thread pool and execution context where message processing occurs. Common choices include:

  • Schedulers.boundedElastic() for I/O-bound operations

  • Schedulers.parallel() for CPU-bound operations

  • Custom schedulers for specific resource management needs

The scheduler is used via publishOn() to ensure message processing happens on the appropriate threads.