Sign in
apache
/
camel
/
aeb57bf9b34658eba075574e03c6132bb07f5382
/
.
/
core
/
camel-core
/
src
/
test
/
java
/
org
/
apache
/
camel
/
processor
/
aggregator
tree: e2d292c3295c5b79b6ebd4c3997a5ca11f9b56b6 [
path history
]
[
tgz
]
AbstractDistributedTest.java
AggregateAggregationStrategyIsPredicateTest.java
AggregateBiFunctionTest.java
AggregateClosedCorrelationKeyTest.java
AggregateCompleteAllOnStopTest.java
AggregateCompletedByBatchConsumerSendEmptyMessageWhenIdleTest.java
AggregateCompletionAwareAggregationStrategyTest.java
AggregateCompletionByBatchConsumerTest.java
AggregateCompletionIntervalTest.java
AggregateCompletionOnlyOneTest.java
AggregateCompletionOnlyTwoTest.java
AggregateCompletionOnNewCorrelationGroupTest.java
AggregateCompletionOnNewCorrelationGroupWithCanPreCompleteTest.java
AggregateCompletionPredicateTest.java
AggregateCompletionSizeAndBatchConsumerTest.java
AggregateCompletionSizeExpressionAndTimeoutTest.java
AggregateConcurrentPerCorrelationKeyTest.java
AggregateControllerTest.java
AggregateDiscardOnFailureTest.java
AggregateDiscardOnTimeoutTest.java
AggregateDslTest.java
AggregateEagerCheckCompletionTest.java
AggregateExpressionSizeFallbackTest.java
AggregateExpressionSizeOverrideFixedTest.java
AggregateExpressionSizeOverrideFixedTimeoutTest.java
AggregateExpressionSizeTest.java
AggregateExpressionTest.java
AggregateExpressionTimeoutFallbackTest.java
AggregateExpressionTimeoutPerGroupTest.java
AggregateExpressionTimeoutTest.java
AggregateForceCompletionHeaderInAggregationStrategyTest.java
AggregateForceCompletionHeaderTest.java
AggregateForceCompletionOnStopParallelTest.java
AggregateForceCompletionOnStopTest.java
AggregateFromWireTapTest.java
AggregateGroupedExchangeBatchSizeTest.java
AggregateGroupedExchangeCompletionExpressionSizeTest.java
AggregateGroupedExchangeCompletionSizeTest.java
AggregateGroupedExchangeMultipleCorrelationTest.java
AggregateGroupedExchangeSizePredicateTest.java
AggregateGroupedExchangeSizeTest.java
AggregateGroupedExchangeTest.java
AggregateGroupMessageTest.java
AggregateIgnoreInvalidCorrelationKeysTest.java
AggregateLostGroupIssueTest.java
AggregateMultipleSourceTest.java
AggregateNewExchangeAndConfirmTest.java
AggregateParallelProcessingTest.java
AggregatePreCompleteAwareStrategyTest.java
AggregatePreCompleteAwareStrategyTimeoutTest.java
AggregatePreCompleteSizeTest.java
AggregateProcessorTest.java
AggregateProcessorTimeoutCompletionRestartTest.java
AggregateRepositoryReturnNullTest.java
AggregateShouldSkipFilteredExchangesTest.java
AggregateShutdownThreadPoolTest.java
AggregateSimpleExpressionIssueManualTest.java
AggregateSimplePredicateEagerTest.java
AggregateSimplePredicateTest.java
AggregateSimpleSizeTest.java
AggregateSimpleTimeoutTest.java
AggregateStrategyRefTest.java
AggregateStrategyServiceTest.java
AggregateThreadPoolProfileTest.java
AggregateTimeoutManualTest.java
AggregateTimeoutOnlyTest.java
AggregateTimeoutTest.java
AggregateTimeoutWithExecutorServiceTest.java
AggregateTimeoutWithNoExecutorServiceTest.java
AggregateUnknownExecutorServiceRefTest.java
AggregationStrategyAsPredicateTest.java
AggregationStrategyBeanAdapterAllowNullOldExchangeTest.java
AggregationStrategyBeanAdapterAllowNullTest.java
AggregationStrategyBeanAdapterNonStaticMethodTest.java
AggregationStrategyBeanAdapterOneMethodTest.java
AggregationStrategyBeanAdapterPollEnrichAllowNullNewExchangeTest.java
AggregationStrategyBeanAdapterPollEnrichTest.java
AggregationStrategyBeanAdapterRefMethodNameTest.java
AggregationStrategyBeanAdapterRefTest.java
AggregationStrategyBeanAdapterStaticMethodTest.java
AggregationStrategyBeanAdapterTest.java
AggregationStrategyBeanAdapterWithHeadersAndPropertiesTest.java
AggregationStrategyBeanAdapterWithHeadersTest.java
AggregationStrategyCompleteByPropertyTest.java
AggregationStrategyGroupedBodyTest.java
AggregationStrategyLifecycleTest.java
AggregatorAndOnExceptionTest.java
AggregatorConcurrencyTest.java
AggregatorExceptionHandleTest.java
AggregatorExceptionInPredicateTest.java
AggregatorExceptionTest.java
AggregatorLockingTest.java
AggregatorTest.java
AlbertoAggregatorTest.java
BeanBeforeAggregateIssueTest.java
BodyOnlyAggregationStrategyTest.java
CustomAggregationStrategyServiceTest.java
CustomAggregationStrategyTest.java
CustomListAggregationStrategyCompletionFromBatchConsumerTest.java
CustomListAggregationStrategyEmptySplitTest.java
CustomListAggregationStrategySplitTest.java
CustomListAggregationStrategyTest.java
DefaultAggregatorCollectionTest.java
DistributedCompletionIntervalTest.java
DistributedConcurrentPerCorrelationKeyTest.java
DistributedOptimisticLockFailingTest.java
DistributedTimeoutTest.java
EnricherRouteNumberOfProcessorTest.java
MyAggregationStrategyService.java
MyCompletionProcessor.java
OptimisticLockRetryPolicyTest.java
PredicateAggregatorCollectionTest.java
SplitAggregateParallelProcessingStackOverflowIssueTest.java
SplitAggregateStackOverflowIssueTest.java
SplitParallelProcessingStackOverflowIssueTest.java
SplitRouteNumberOfProcessorTest.java
SplitStackOverflowIssueTest.java
StringAggregationStrategyTest.java