diff --git a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/MulticastReifier.java b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/MulticastReifier.java index 20bdfc3e2f2df..853cfb744210f 100644 --- a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/MulticastReifier.java +++ b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/MulticastReifier.java @@ -34,6 +34,8 @@ import org.apache.camel.processor.aggregate.UseLatestAggregationStrategy; public class MulticastReifier extends ProcessorReifier { + + private static final int ERROR_HANDLERS_CACHE_SIZE = 100; public MulticastReifier(Route route, ProcessorDefinition definition) { super(route, (MulticastDefinition) definition); @@ -78,7 +80,7 @@ protected Processor createCompositeProcessor(List list) throws Except MulticastProcessor answer = new MulticastProcessor( camelContext, route, list, strategy, isParallelProcessing, threadPool, shutdownThreadPool, isStreaming, - isStopOnException, timeout, prepare, isShareUnitOfWork, isParallelAggregate, 0); + isStopOnException, timeout, prepare, isShareUnitOfWork, isParallelAggregate, ERROR_HANDLERS_CACHE_SIZE); answer.setSynchronous(isSynchronous); return answer; }