Event Processing Queues
Advanced users may want to tune the level of concurrency which may be used for delivery of events.
CacheConfiguration<Long, String> cacheConfiguration =
CacheConfigurationBuilder.newCacheConfigurationBuilder(Long.class,
String.class, ResourcePoolsBuilder.heap(5L))
.withDispatcherConcurrency(10) // 1
.withEventListenersThreadPool("listeners-pool")
.build();
1 | Indicate the level of concurrency desired |
This will enable parallel processing of events at the cost of more threads being required by the system.