This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a change to branch sandbox/camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 79b9bb3 Regen
new 890cff4 Fix jackson converter test (broken by the removal of the optimized converter)
new cf33e65 Fix cxf tests
new d17a41f Full asynchronous engine with low stack depth
new 6376c6e Introduce AsyncProcessorSupport to remove the number of dumb sync process()
implementations
new 6d56ee1 Rewrite load balancers to be fully async
new b8840a1 Improve aggregator to be more asynchronous and non blocking when using optimistic
locking
new 2a79d6c Add a method returning a CompletableFuture to AsyncProcessor
new 6094865 Fix async engine / tests
new 1148434 Flag mojos as threadsafe
new cec9ef0 Fix camel-aws-xray for async engine
new 93fbf29 Merge branch 'camel-3.x-async' into camel-3.x
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../main/java/org/apache/camel/AsyncProcessor.java | 5 +
.../camel/spi/AsyncProcessorAwaitManager.java | 19 +-
camel-core/pom.xml | 5 +
camel-core/src/main/docs/eips/delay-eip.adoc | 2 +-
.../component/bean/AbstractBeanProcessor.java | 24 +-
.../apache/camel/component/bean/BeanProcessor.java | 7 +
.../apache/camel/component/file/FileConsumer.java | 23 +-
.../apache/camel/component/seda/SedaProducer.java | 1 -
.../camel/component/timer/TimerConsumer.java | 5 +
.../apache/camel/impl/AbstractCamelContext.java | 87 +-
.../impl/DefaultAsyncProcessorAwaitManager.java | 32 +-
.../apache/camel/impl/DefaultProducerCache.java | 12 +-
.../java/org/apache/camel/impl/DeferProducer.java | 9 +
.../impl/InterceptSendToEndpointProcessor.java | 8 +-
.../camel/impl/SubscribeMethodProcessor.java | 10 +-
.../impl/cloud/DefaultServiceCallProcessor.java | 17 +-
.../org/apache/camel/model/DelayDefinition.java | 12 +-
.../camel/processor/CamelInternalProcessor.java | 103 +-
.../apache/camel/processor/CamelLogProcessor.java | 54 +-
.../apache/camel/processor/ChoiceProcessor.java | 9 +-
.../camel/processor/ClaimCheckProcessor.java | 10 +-
.../camel/processor/ConvertBodyProcessor.java | 38 +-
.../camel/processor/DelayProcessorSupport.java | 23 +-
.../camel/processor/DelegateAsyncProcessor.java | 24 +-
.../camel/processor/DelegateSyncProcessor.java | 13 +-
.../java/org/apache/camel/processor/Enricher.java | 9 +-
.../processor/EvaluateExpressionProcessor.java | 10 +-
.../camel/processor/ExchangePatternProcessor.java | 10 +-
.../InterceptorToAsyncProcessorBridge.java | 10 +
.../org/apache/camel/processor/LogProcessor.java | 10 +-
.../org/apache/camel/processor/LoopProcessor.java | 176 +-
.../apache/camel/processor/MarshalProcessor.java | 10 +-
.../apache/camel/processor/MulticastProcessor.java | 794 +++------
.../camel/processor/OnCompletionProcessor.java | 10 +-
.../java/org/apache/camel/processor/Pipeline.java | 176 +-
.../org/apache/camel/processor/PollEnricher.java | 10 +-
.../org/apache/camel/processor/RecipientList.java | 10 +-
.../camel/processor/RedeliveryErrorHandler.java | 1769 +++++++++-----------
.../camel/processor/RemoveHeaderProcessor.java | 10 +-
.../camel/processor/RemoveHeadersProcessor.java | 10 +-
.../camel/processor/RemovePropertiesProcessor.java | 10 +-
.../camel/processor/RemovePropertyProcessor.java | 10 +-
.../org/apache/camel/processor/Resequencer.java | 30 +-
.../apache/camel/processor/RollbackProcessor.java | 10 +-
.../org/apache/camel/processor/RoutingSlip.java | 20 +-
.../apache/camel/processor/SamplingThrottler.java | 19 +-
.../apache/camel/processor/ScriptProcessor.java | 10 +-
.../camel/processor/SendDynamicProcessor.java | 10 +-
.../org/apache/camel/processor/SendProcessor.java | 20 +-
.../apache/camel/processor/SetBodyProcessor.java | 10 +-
.../apache/camel/processor/SetHeaderProcessor.java | 10 +-
.../camel/processor/SetPropertyProcessor.java | 10 +-
.../processor/SharedCamelInternalProcessor.java | 57 +-
.../org/apache/camel/processor/SortProcessor.java | 10 +-
.../java/org/apache/camel/processor/Splitter.java | 14 +-
.../org/apache/camel/processor/StopProcessor.java | 10 +-
.../apache/camel/processor/StreamResequencer.java | 10 +-
.../apache/camel/processor/ThreadsProcessor.java | 10 +-
.../java/org/apache/camel/processor/Throttler.java | 11 +-
.../apache/camel/processor/ThroughputLogger.java | 14 +-
.../camel/processor/ThrowExceptionProcessor.java | 10 +-
.../apache/camel/processor/TransformProcessor.java | 10 +-
.../org/apache/camel/processor/TryProcessor.java | 99 +-
.../apache/camel/processor/UnitOfWorkProducer.java | 3 +-
.../apache/camel/processor/UnmarshalProcessor.java | 10 +-
.../apache/camel/processor/WireTapProcessor.java | 31 +-
.../processor/aggregate/AggregateProcessor.java | 349 ++--
.../aggregate/OptimisticLockRetryPolicy.java | 15 +-
.../processor/idempotent/IdempotentConsumer.java | 9 +-
.../processor/interceptor/DefaultChannel.java | 13 -
.../processor/loadbalancer/DistributionRatio.java | 37 +-
.../loadbalancer/FailOverLoadBalancer.java | 214 +--
.../camel/processor/loadbalancer/LoadBalancer.java | 6 +-
.../loadbalancer/LoadBalancerConsumer.java | 4 +-
.../loadbalancer/LoadBalancerSupport.java | 77 +-
.../processor/loadbalancer/QueueLoadBalancer.java | 30 +-
.../processor/loadbalancer/RandomLoadBalancer.java | 19 +-
.../loadbalancer/RoundRobinLoadBalancer.java | 22 +-
.../processor/loadbalancer/StickyLoadBalancer.java | 36 +-
.../processor/loadbalancer/TopicLoadBalancer.java | 50 +-
.../loadbalancer/WeightedLoadBalancer.java | 74 +-
.../loadbalancer/WeightedRandomLoadBalancer.java | 51 +-
.../WeightedRoundRobinLoadBalancer.java | 40 +-
.../processor/validation/ValidatingProcessor.java | 19 +-
.../org/apache/camel/reifier/DelayReifier.java | 2 +-
.../apache/camel/reifier/LoadBalanceReifier.java | 6 +-
.../org/apache/camel/reifier/ProcessorReifier.java | 25 +-
.../org/apache/camel/reifier/WireTapReifier.java | 2 +-
.../support/AsyncProcessorConverterHelper.java | 9 +
.../apache/camel/support/AsyncProcessorHelper.java | 18 +-
.../AsyncProcessorSupport.java} | 52 +-
.../apache/camel/support/DefaultAsyncProducer.java | 13 +-
.../org/apache/camel/support/DefaultConsumer.java | 10 +-
.../apache/camel/support/DefaultTimeoutMap.java | 57 +-
.../NoLock.java} | 51 +-
.../org/apache/camel/support/ReactiveHelper.java | 164 ++
.../component/seda/SedaBlockWhenFullTest.java | 4 +-
.../seda/SedaDefaultBlockWhenFullTest.java | 4 +-
.../camel/impl/MultipleConsumersSupportTest.java | 8 +
...ngExchangesAsyncDelayShutdownGracefulTest.java} | 31 +-
.../impl/PendingExchangesShutdownGracefulTest.java | 2 +-
...ndingExchangesTwoRouteShutdownGracefulTest.java | 4 +-
.../EventNotifierFailureHandledEventsTest.java | 8 +-
.../CharlesSplitAndTryCatchRollbackIssueTest.java | 4 +-
...thAggregationStrategyThrowingExceptionTest.java | 11 +-
...terParallelRuntimeExceptionInHasNextOrNext.java | 12 -
...ThreadsRejectedExecutionWithDeadLetterTest.java | 4 +-
.../apache/camel/processor/LoopAsyncCopyTest.java | 3 -
.../camel/processor/LoopAsyncNoCopyTest.java | 3 -
.../org/apache/camel/processor/MDCAsyncTest.java | 17 +-
.../MulticastParallelStopOnExceptionTest.java | 3 +-
.../processor/MulticastParallelStreamingTest.java | 2 +-
.../processor/MulticastStopOnExceptionTest.java | 2 +-
.../apache/camel/processor/NavigateRouteTest.java | 22 +-
...pientListContextScopedOnExceptionIssueTest.java | 7 +
.../processor/ShutdownCompleteAllTasksTest.java | 2 +-
.../ShutdownCompleteCurrentTaskOnlyTest.java | 4 +-
.../SplitterParallelStopOnExceptionTest.java | 2 +-
.../processor/SplitterStopOnExceptionTest.java | 2 +-
.../processor/ThreadsRejectedExecutionTest.java | 2 +-
.../camel/processor/UnmarshalProcessorTest.java | 2 +
.../aggregator/AggregateProcessorTest.java | 45 +-
...egateProcessorTimeoutCompletionRestartTest.java | 7 +-
.../async/AsyncEndpointCustomInterceptorTest.java | 9 +-
.../processor/async/AsyncEndpointPolicyTest.java | 38 +-
.../AsyncEndpointRecipientListParallel5Test.java | 3 +-
.../AsyncEndpointRecipientListParallelTest.java | 3 +-
...syncEndpointRoutingSlipBeanNonBlockingTest.java | 8 +-
.../routingslip/RoutingSlipEventNotifierTest.java | 1 +
.../java/org/apache/camel/util/FilterIterator.java | 88 +
.../main/java/org/apache/camel/util/IOHelper.java | 10 +-
.../util/concurrent/AsyncCompletionService.java | 167 ++
.../concurrent/AsyncCompletionServiceTest.java | 196 +++
.../client/AbstractAtomixClientProducer.java | 9 +-
.../camel/component/aws/xray/XRayTracer.java | 127 +-
.../camel/component/aws/xray/ABCRouteTest.java | 11 +-
.../aws/xray/ComprehensiveTrackingTest.java | 22 +-
.../component/aws/xray/CustomComponentTest.java | 5 +-
.../aws/xray/SpringAwsXRaySimpleRouteTest.java | 25 +-
.../camel/component/aws/xray/TwoService2Test.java | 7 +-
.../camel/component/aws/xray/TwoServiceTest.java | 5 +-
.../src/test/resources/log4j2.properties | 39 +
.../component/beanstalk/BeanstalkProducer.java | 5 +-
.../cdi/transaction/TransactionErrorHandler.java | 9 +
.../apache/camel/component/cxf/CxfProducer.java | 3 +-
.../camel/component/cxf/jaxrs/CxfRsProducer.java | 3 +-
.../cxf/CxfConsumerContinuationTimeoutTest.java | 8 +-
.../component/cxf/CxfMessageHeaderTimeoutTest.java | 3 +-
.../apache/camel/component/cxf/CxfTimeoutTest.java | 3 +-
.../disruptor/DisruptorConcurrentTest.java | 4 +-
.../docker/producer/AsyncDockerProducer.java | 5 +-
.../file/remote/FromFtpAsyncProcessTest.java | 8 +-
.../FtpShutdownCompleteCurrentTaskOnlyTest.java | 2 +-
.../apache/camel/component/grpc/GrpcProducer.java | 7 +-
.../hystrix/processor/HystrixProcessor.java | 11 +-
.../ignite/cache/IgniteCacheProducer.java | 3 +-
.../ignite/compute/IgniteComputeProducer.java | 9 +-
.../ignite/idgen/IgniteIdGenProducer.java | 5 +-
.../ignite/messaging/IgniteMessagingProducer.java | 4 +-
.../ignite/queue/IgniteQueueProducer.java | 5 +-
.../component/ignite/set/IgniteSetProducer.java | 5 +-
.../jackson/converter/JacksonTypeConverters.java | 2 +-
.../component/netty4/NettyRedeliveryTest.java | 5 +-
.../camel/component/quartz2/QuartzEndpoint.java | 4 +-
.../streams/util/UnwrapStreamProcessor.java | 9 +-
.../camel/component/event/EventEndpoint.java | 4 +-
.../camel/spring/spi/TransactionErrorHandler.java | 32 +-
.../processor/ShutdownCompleteAllTasksTest.xml | 2 +-
.../ShutdownCompleteCurrentTaskOnlyTest.xml | 2 +-
.../maven/bom/generator/BomGeneratorMojo.java | 1 +
.../packaging/PackageArchetypeCatalogMojo.java | 1 +
.../maven/packaging/PackageComponentMojo.java | 1 +
.../maven/packaging/PackageDataFormatMojo.java | 1 +
.../camel/maven/packaging/PackageLanguageMojo.java | 1 +
.../camel/maven/packaging/PackageModelMojo.java | 1 +
.../camel/maven/packaging/PackageOtherMojo.java | 1 +
.../maven/packaging/PrepareCatalogKarafMojo.java | 1 +
.../camel/maven/packaging/PrepareCatalogMojo.java | 1 +
.../packaging/PrepareCatalogSpringBootMojo.java | 1 +
.../maven/packaging/PrepareComponentMojo.java | 1 +
.../camel/maven/packaging/PrepareExampleMojo.java | 1 +
.../camel/maven/packaging/PrepareReadmeMojo.java | 1 +
.../maven/packaging/PrepareUserGuideMojo.java | 1 +
.../packaging/SpringBootAutoConfigurationMojo.java | 1 +
.../maven/packaging/SpringBootStarterMojo.java | 1 +
.../camel/maven/packaging/UpdateReadmeMojo.java | 1 +
...pdateSpringBootAutoConfigurationReadmeMojo.java | 1 +
.../maven/packaging/ValidateComponentMojo.java | 1 +
188 files changed, 3135 insertions(+), 3554 deletions(-)
copy camel-core/src/main/java/org/apache/camel/{processor/StopProcessor.java => support/AsyncProcessorSupport.java}
(55%)
rename camel-core/src/main/java/org/apache/camel/{processor/loadbalancer/SimpleLoadBalancerSupport.java
=> support/NoLock.java} (52%)
create mode 100644 camel-core/src/main/java/org/apache/camel/support/ReactiveHelper.java
copy camel-core/src/test/java/org/apache/camel/impl/{PendingExchangesShutdownGracefulTest.java
=> PendingExchangesAsyncDelayShutdownGracefulTest.java} (61%)
create mode 100644 camel-util/src/main/java/org/apache/camel/util/FilterIterator.java
create mode 100644 camel-util/src/main/java/org/apache/camel/util/concurrent/AsyncCompletionService.java
create mode 100644 camel-util/src/test/java/org/apache/camel/util/concurrent/AsyncCompletionServiceTest.java
create mode 100644 components/camel-aws-xray/src/test/resources/log4j2.properties
|