This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 6c65866e7c1 CAMEL-19033: camel-jbang - Add trace command
new 72c146dc9ea CAMEL-15105: decouple the ExtendedExchange from the
Exchange
new db69991c067 CAMEL-15105: convert setting notify events in camel-cdi
and camel-management
new 67cf609766e CAMEL-15105: rework usages of ExtendedExchange in
ExchangeHelper
new 04ac187cf48 CAMEL-15105: rework handling addOnCompletions on Exchanges
in camel-core module
new 43a6574cbd6 CAMEL-15105: rework handling addOnCompletions on Exchanges
in several components
new 812786f9d92 CAMEL-15105: rework handoverCompletions in AbstractExchange
new dbbf0060ad9 CAMEL-15105: rework setting history properties the
camel-core code
new cd3f7313842 CAMEL-15105: rework managing error handling properties in
the exchange
new 57d5f57077a CAMEL-15105: rework handling the unit of work
new ceaffab948b CAMEL-15105: rework redelivery handling
new 5e7f751fccb CAMEL-15105: adapt the RedeliveryErrorHandler to the new
extension interface
new 85e12ebe270 CAMEL-15105: rework setting from route/endpoint properties
new d5989c41660 CAMEL-15105: adapt the DefaultConsumer to the new
extension interface
new 7e6da1de5bb CAMEL-15105: adapt DefaultConsumerTemplate to the new
extension interface
new 44e139333ae CAMEL-15105: adapt DefaultNettyHttpBinding to the new
extension interface
new d2e8b0fcef3 CAMEL-15105: adapt camel-salesforce to the new extension
interface
new 5d4c96d306c CAMEL-15105: code cleanups in the camel-core
new a3c41472a7d CAMEL-15105: adapt and cleanup camel-components to the new
extension interface
new 70b31903962 CAMEL-15105: adapt and cleanup camel-core to the new
extension interface
new 48fd93058a8 CAMEL-15105: adapted the copy exchange logic in
AbstractExchange
new aec1d1d0596 CAMEL-15105: removed the extended exchange imports
new 94b807e5c5e CAMEL-15105: deprecated and cleaned up the
ExtendedExchange API interface
new a91ba7e68ed CAMEL-15105: remove unnecessary adapt to Exchange
The 23 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:
.../camel/attachment/DefaultAttachmentMessage.java | 31 ++-
.../camel/component/aws2/s3/AWS2S3Consumer.java | 5 +-
.../camel/component/aws2/sqs/Sqs2Consumer.java | 5 +-
.../component/azure/cosmosdb/CosmosDbConsumer.java | 3 +-
.../azure/eventhubs/EventHubsConsumer.java | 3 +-
.../azure/servicebus/ServiceBusConsumer.java | 3 +-
.../component/azure/storage/blob/BlobConsumer.java | 3 +-
.../azure/storage/datalake/DataLakeConsumer.java | 3 +-
.../azure/storage/queue/QueueConsumer.java | 3 +-
.../aggregate/cassandra/CassandraCamelCodec.java | 3 +-
.../language/csimple/joor/OriginalSimpleTest.java | 12 +-
.../camel/dataformat/csv/CsvUnmarshaller.java | 3 +-
.../jaxrs/CxfRsConsumerClientDisconnectedTest.java | 3 +-
.../component/cxf/jaxrs/CxfRsStreamCacheTest.java | 3 +-
.../component/cxf/jaxws/DefaultCxfBinding.java | 3 +-
.../jaxws/CxfConsumerClientDisconnectedTest.java | 3 +-
.../cxf/jaxws/CxfConsumerStreamCacheTest.java | 3 +-
.../component/directvm/DirectVmProcessor.java | 3 +-
.../disruptor/AbstractSynchronizedExchange.java | 5 +-
.../component/disruptor/DisruptorConsumer.java | 5 +-
.../component/disruptor/DisruptorProducer.java | 5 +-
.../DisruptorInOutChainedWithOnCompletionTest.java | 3 +-
...sruptorWaitForTaskCompleteOnCompletionTest.java | 3 +-
.../DisruptorWaitForTaskNeverOnCompletionTest.java | 3 +-
.../camel/component/file/GenericFileConsumer.java | 3 +-
.../component/file/remote/RemoteFileConsumer.java | 3 +-
.../mail/stream/GoogleMailStreamConsumer.java | 3 +-
.../google/pubsub/GooglePubsubConsumer.java | 3 +-
.../pubsub/consumer/CamelMessageReceiver.java | 3 +-
.../google/storage/GoogleCloudStorageConsumer.java | 3 +-
.../apache/camel/component/hdfs/HdfsConsumer.java | 3 +-
.../apache/camel/component/http/HttpProducer.java | 3 +-
.../component/huaweicloud/obs/OBSConsumer.java | 3 +-
.../ignite/cache/IgniteCacheProducer.java | 3 +-
.../camel/component/ironmq/IronMQConsumer.java | 3 +-
.../apache/camel/component/jdbc/JdbcProducer.java | 5 +-
.../component/jetty/CamelContinuationServlet.java | 4 +-
.../org/apache/camel/component/jpa/JpaHelper.java | 3 +-
.../kamelet/KameletConsumerUoWIssueTest.java | 3 +-
.../component/kamelet/KameletUoWIssueTest.java | 3 +-
.../camel/component/leveldb/LevelDBCamelCodec.java | 3 +-
.../apache/camel/component/mail/MailConsumer.java | 3 +-
.../faulttolerance/FaultToleranceProcessor.java | 7 +-
.../camel/component/minio/MinioConsumer.java | 5 +-
.../netty/http/DefaultNettyHttpBinding.java | 9 +-
.../component/netty/http/NettyHttpProducer.java | 5 +-
.../camel/component/netty/NettyProducer.java | 3 +-
.../slot/PgReplicationSlotConsumer.java | 3 +-
.../apache/camel/pgevent/PgEventConsumerTest.java | 8 +-
.../http/vertx/VertxPlatformHttpConsumer.java | 3 +-
.../http/JettyCustomPlatformHttpConsumer.java | 3 +-
.../engine/DefaultCamelReactiveStreamsService.java | 3 +-
.../reactor/engine/ReactorStreamsService.java | 3 +-
.../resilience4j/ResilienceProcessor.java | 5 +-
.../rxjava/engine/RxJavaStreamsService.java | 3 +-
.../salesforce/SalesforceConsumerTest.java | 8 +-
.../apache/camel/component/seda/SedaConsumer.java | 8 +-
.../apache/camel/component/seda/SedaProducer.java | 3 +-
.../apache/camel/component/sjms/SjmsTemplate.java | 13 +-
.../spring/ws/SpringWebserviceConsumer.java | 3 +-
...lClientDataSourceOnExceptionRedeliveryTest.java | 3 +-
...ransactionalClientDataSourceRedeliveryTest.java | 3 +-
.../apache/camel/component/sql/SqlProducer.java | 3 +-
.../processor/aggregate/jdbc/JdbcCamelCodec.java | 3 +-
.../aggregate/tarfile/TarAggregationStrategy.java | 5 +-
.../org/apache/camel/component/vm/VmConsumer.java | 6 +-
.../apache/camel/component/xslt/XsltBuilder.java | 4 +-
.../aggregate/zipfile/ZipAggregationStrategy.java | 5 +-
.../src/main/java/org/apache/camel/Exchange.java | 5 +
...xtendedExchange.java => ExchangeExtension.java} | 179 ++++++++---------
.../java/org/apache/camel/ExtendedExchange.java | 220 +--------------------
.../main/java/org/apache/camel/PooledExchange.java | 2 +-
.../java/org/apache/camel/SafeCopyProperty.java | 4 +-
.../camel/impl/engine/CamelInternalProcessor.java | 34 ++--
.../engine/DefaultAsyncProcessorAwaitManager.java | 5 +-
.../camel/impl/engine/DefaultConsumerTemplate.java | 3 +-
.../impl/engine/DefaultInflightRepository.java | 3 +-
.../camel/impl/engine/DefaultUnitOfWork.java | 10 +-
.../engine/PooledProcessorExchangeFactory.java | 9 +-
.../impl/event/ExchangeFailureHandledEvent.java | 5 +-
.../org/apache/camel/processor/CatchProcessor.java | 18 +-
.../java/org/apache/camel/processor/Enricher.java | 5 +-
.../camel/processor/FatalFallbackErrorHandler.java | 7 +-
.../apache/camel/processor/MulticastProcessor.java | 8 +-
.../camel/processor/OnCompletionProcessor.java | 42 ++--
.../org/apache/camel/processor/PipelineHelper.java | 10 +-
.../org/apache/camel/processor/PollEnricher.java | 5 +-
.../camel/processor/RecipientListProcessor.java | 3 +-
.../java/org/apache/camel/processor/Splitter.java | 3 +-
.../processor/aggregate/AggregateProcessor.java | 7 +-
.../ShareUnitOfWorkAggregationStrategy.java | 12 +-
.../aggregate/UseLatestAggregationStrategy.java | 6 +-
.../processor/errorhandler/NoErrorHandler.java | 3 +-
.../errorhandler/RedeliveryErrorHandler.java | 69 +++----
.../processor/idempotent/IdempotentConsumer.java | 3 +-
.../camel/processor/resume/ResumableProcessor.java | 3 +-
.../transformer/ProcessorTransformer.java | 3 +-
.../apache/camel/builder/xml/XsltBuilderTest.java | 3 +-
.../seda/SedaDiscardIfNoConsumerTest.java | 3 +-
.../seda/SedaInOutChainedWithOnCompletionTest.java | 3 +-
.../SedaWaitForTaskCompleteOnCompletionTest.java | 3 +-
.../seda/SedaWaitForTaskNewerOnCompletionTest.java | 3 +-
.../converter/stream/CachedOutputStreamTest.java | 3 +-
.../DefaultAsyncProcessorAwaitManagerTest.java | 3 +-
.../org/apache/camel/impl/DefaultExchangeTest.java | 5 +-
.../impl/engine/CamelPostProcessorHelperTest.java | 5 +-
.../org/apache/camel/issues/GertJBIIssueTest.java | 7 +-
.../apache/camel/language/simple/SimpleTest.java | 11 +-
.../camel/processor/EnrichWithUnitOfWorkTest.java | 5 +-
.../processor/MDCOnCompletionOnCompletionTest.java | 3 +-
.../camel/processor/OnCompletionContainsTest.java | 15 +-
.../processor/OnCompletionShouldBeLastTest.java | 7 +-
.../processor/RouteAwareSynchronizationTest.java | 3 +-
.../camel/processor/UnitOfWorkHelperTest.java | 4 +-
.../BodyOnlyAggregationStrategyTest.java | 5 +-
.../processor/async/AsyncEndpointDelayUoWTest.java | 7 +-
.../async/AsyncEndpointUoWFailedTest.java | 8 +-
.../processor/async/AsyncEndpointUoWTest.java | 7 +-
.../camel/management/PublishEventNotifier.java | 5 +-
.../converter/stream/FileInputStreamCache.java | 3 +-
.../org/apache/camel/support/AbstractExchange.java | 173 ++++------------
.../BridgeExceptionHandlerToErrorHandler.java | 3 +-
.../org/apache/camel/support/DefaultConsumer.java | 13 +-
.../camel/support/EventDrivenPollingConsumer.java | 3 +-
.../java/org/apache/camel/support/EventHelper.java | 19 +-
.../org/apache/camel/support/ExchangeHelper.java | 26 ++-
.../camel/support/ExtendedExchangeExtension.java | 216 ++++++++++++++++++++
.../org/apache/camel/support/MessageHelper.java | 7 +-
.../camel/support/builder/ExpressionBuilder.java | 2 +-
.../jetty/JettySimulateFailoverRoundRobinTest.java | 3 +-
130 files changed, 682 insertions(+), 893 deletions(-)
copy core/camel-api/src/main/java/org/apache/camel/{ExtendedExchange.java =>
ExchangeExtension.java} (92%)
create mode 100644
core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java
