When your Hystrix command extends from HystrixCommand, you can specify the queue size for the thread pool as follows:
..
.andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
.withMaxQueueSize(10)
.withQueueSizeRejectionThreshold(10));
But when expanding from HystrixObservableCommandthere (obviously) there is no threadpool to configure the queue size for. But what if you still want to allow queued requests for HystrixObservableCommandwhen it ExecutionIsolationSemaphoreMaxConcurrentRequestsreaches its limit?
- Does Hystrix provide any support for this, or is it something you need to roll on your own?
- If the latter, then how could you realize this in an idiomatic way?
Johan source
share