Sign in
apache
/
camel
/
refs/heads/camel-2.12.x
/
.
/
camel-core
/
src
/
test
/
java
/
org
/
apache
/
camel
/
processor
/
aggregator
tree: 9a7793fd032cb836a9e188c032e7802ca200733b [
path history
]
[
tgz
]
AbstractDistributedTest.java
AggregateClosedCorrelationKeyTest.java
AggregateCompletedByBatchConsumerSendEmptyMessageWhenIdleTest.java
AggregateCompletionAwareAggregationStrategyTest.java
AggregateCompletionIntervalTest.java
AggregateCompletionOnlyOneTest.java
AggregateCompletionOnlyTwoTest.java
AggregateCompletionPredicateTest.java
AggregateCompletionSizeAndBatchConsumerTest.java
AggregateCompletionSizeExpressionAndTimeoutTest.java
AggregateConcurrentPerCorrelationKeyTest.java
AggregateDiscardOnTimeoutTest.java
AggregateEagerCheckCompletionTest.java
AggregateExpressionSizeFallbackTest.java
AggregateExpressionSizeOverrideFixedTest.java
AggregateExpressionSizeOverrideFixedTimeoutTest.java
AggregateExpressionSizeTest.java
AggregateExpressionTest.java
AggregateExpressionTimeoutFallbackTest.java
AggregateExpressionTimeoutPerGroupTest.java
AggregateExpressionTimeoutTest.java
AggregateForceCompletionHeaderTest.java
AggregateForceCompletionOnStopParallelTest.java
AggregateForceCompletionOnStopTest.java
AggregateFromWireTapTest.java
AggregateGroupedExchangeBatchSizeTest.java
AggregateGroupedExchangeCompletionExpressionSizeTest.java
AggregateGroupedExchangeCompletionSizeTest.java
AggregateGroupedExchangeMultipleCorrelationTest.java
AggregateGroupedExchangeSizePredicateTest.java
AggregateGroupedExchangeSizeTest.java
AggregateGroupedExchangeTest.java
AggregateIgnoreInvalidCorrelationKeysTest.java
AggregateLostGroupIssueTest.java
AggregateMultipleSourceTest.java
AggregateNewExchangeAndConfirmTest.java
AggregateParallelProcessingTest.java
AggregateProcessorTest.java
AggregateProcessorTimeoutCompletionRestartTest.java
AggregateRepositoryReturnNullTest.java
AggregateShouldSkipFilteredExchangesTest.java
AggregateShutdownThreadPoolTest.java
AggregateSimpleExpressionIssueTest.java
AggregateSimplePredicateEagerTest.java
AggregateSimplePredicateTest.java
AggregateSimpleSizeTest.java
AggregateSimpleTimeoutTest.java
AggregateStrategyServiceTest.java
AggregateThreadPoolProfileTest.java
AggregateTimeoutManualTest.java
AggregateTimeoutOnlyTest.java
AggregateTimeoutTest.java
AggregateTimeoutWithExecutorServiceTest.java
AggregateTimeoutWithNoExecutorServiceTest.java
AggregateUnknownExecutorServiceRefTest.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
AggregatorAndOnExceptionTest.java
AggregatorConcurrencyTest.java
AggregatorExceptionHandleTest.java
AggregatorExceptionInPredicateTest.java
AggregatorExceptionTest.java
AggregatorTest.java
AlbertoAggregatorTest.java
BeanBeforeAggregateIssueTest.java
CustomAggregationStrategyServiceTest.java
CustomAggregationStrategyTest.java
CustomListAggregationStrategyCompletionFromBatchConsumerTest.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
SplitRouteNumberOfProcessorTest.java