Skip to content

Commit a25e428

Browse files
DPE-1775 cMulticast is not sending the message to the target endpoint when it get a message from cOnException
1 parent 81e024a commit a25e428

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

core/camel-core-reifier/src/main/java/org/apache/camel/reifier/MulticastReifier.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,8 @@
3434
import org.apache.camel.processor.aggregate.UseLatestAggregationStrategy;
3535

3636
public class MulticastReifier extends ProcessorReifier<MulticastDefinition> {
37+
38+
private static final int ERROR_HANDLERS_CACHE_SIZE = 100;
3739

3840
public MulticastReifier(Route route, ProcessorDefinition<?> definition) {
3941
super(route, (MulticastDefinition) definition);
@@ -78,7 +80,7 @@ protected Processor createCompositeProcessor(List<Processor> list) throws Except
7880

7981
MulticastProcessor answer = new MulticastProcessor(
8082
camelContext, route, list, strategy, isParallelProcessing, threadPool, shutdownThreadPool, isStreaming,
81-
isStopOnException, timeout, prepare, isShareUnitOfWork, isParallelAggregate, 0);
83+
isStopOnException, timeout, prepare, isShareUnitOfWork, isParallelAggregate, ERROR_HANDLERS_CACHE_SIZE);
8284
answer.setSynchronous(isSynchronous);
8385
return answer;
8486
}

0 commit comments

Comments
 (0)