This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-25928-eip-result-type
in repository https://gitbox.apache.org/repos/asf/camel.git
from 31eae2c44460 CAMEL-25928: camel-catalog - review fixes: the
javaTypeOption error message, and why java.lang.byte[] is a carrier name
add ce9b4c8555e7 CAMEL-26060: camel-file-watch - Set CamelFileLastModified
to the last modified time of the file (#28361)
add 232c79615dd2 CAMEL-25856: camel-file - keep the lock of a file name
while it is in use (#28379)
add 61952f53597b CAMEL-25864: camel-core - an aggregator recovers only the
exchanges it completed in an auto-discovered KeyValueRepository (#28383)
add d77f4acb888b CAMEL-25898: camel-ibm-cos - the producer stores an
object in the bucket of its endpoint, not in the bucket the consumer took it
from (#28426)
add 8bc49f315393 CAMEL-25903: camel-aws2-s3 - a multipart upload stores
the user metadata of the CamelAwsS3Metadata header (#28427)
add b3e290788209 CAMEL-25904: camel-beanio - BeanIOSplitter decodes a file
or stream with the charset of the exchange or its encoding (#28428)
add 96725b787a60 CAMEL-25905: camel-file - the checksum of
checksumFileAlgorithm is calculated from the bytes written to the file (#28429)
add 87dd1cfbc795 CAMEL-25907: camel-elasticsearch, camel-opensearch - a
producer no longer closes the client of the component (#28431)
add ad9645a6237a CAMEL-25908: camel-knative-http - a consumer started
again receives the requests of its path again (#28432)
add 4ee3a7e1dd08 CAMEL-25909: camel-aws2-kinesis - each endpoint uses and
closes its own client (#28433)
add 86f1e5f46277 CAMEL-25883: camel-jgroups-raft - an endpoint no longer
disconnects or closes the RaftHandle of the component while other endpoints use
it (#28425)
add 9092699ed409 CAMEL-26105: upgrade guide - the aws2-athena queryString
order note for 4.22.3 and 4.18.6 (#28408)
add fd2778e6e9ed chore: upgrade guide - remove the camel-solr note from
4.18.6 and 4.22.3
add 5c9bf8387721 chore: docs - export the vault environment variables
without a $ before the name
add 187bcde98c2c CAMEL-25847: camel-nats - a stopped JetStream push
consumer unsubscribes through its dispatcher (#28320)
add 68600099ae46 CAMEL-26295: camel-jbang - the source editor checks the
message body of a YAML route as the file opens and while you type, not only on
save
add c10c5f832558 CAMEL-25906: camel-file - the remote file producers write
the checksum of checksumFileAlgorithm again, of the file they upload (#28430)
add c536c99caaaa CAMEL-25911: camel-test-dst - stage 2: an internal
TimeSource in camel-util for core waits, task timing and throttling (#28382)
add b3906805c843 CAMEL-25928: camel-catalog - the body types of the EIPs:
the body after each EIP, the body its own steps start with, and the side of
another model it comes from (#28424)
add 5658636edf6e CAMEL-26293: docs - examples with options that do not
exist or values Camel does not read (#28438)
add c2ef076d1851 Merge remote-tracking branch 'origin/main' into
CAMEL-25928-eip-result-type
No new revisions were added by this update.
Summary of changes:
.../camel/catalog/components/file-watch.json | 2 +-
.../apache/camel/catalog/components/ibm-cos.json | 5 +-
.../docs/aws-secrets-manager-component.adoc | 4 +-
.../catalog/docs/azure-key-vault-component.adoc | 24 +-
.../camel/catalog/docs/file-watch-component.adoc | 12 +-
.../docs/google-secret-manager-component.adoc | 12 +-
.../camel/catalog/docs/ibm-cos-component.adoc | 6 +-
.../camel/catalog/docs/keyValueRepository.adoc | 10 +
.../apache/camel/catalog/docs/opentelemetry2.adoc | 2 +-
.../org/apache/camel/catalog/docs/test-dst.adoc | 77 +++-
.../main/docs/aws-secrets-manager-component.adoc | 4 +-
.../component/aws2/kinesis/Kinesis2Component.java | 4 +
.../component/aws2/kinesis/Kinesis2Endpoint.java | 21 +-
.../component/aws2/kinesis/KinesisConnection.java | 47 ++-
.../aws2/kinesis/KinesisEndpointClientTest.java | 151 +++++++
.../camel/component/aws2/s3/AWS2S3Producer.java | 3 +-
...va => AWS2S3ProducerMultipartMetadataTest.java} | 91 ++---
...ilityDstTest.java => SqsRedeliveryDstTest.java} | 18 +-
.../camel/component/aws2/sqs/dst/SqsWorld.java | 58 ++-
.../src/main/docs/azure-key-vault-component.adoc | 24 +-
.../camel/dataformat/beanio/BeanIOSplitter.java | 38 +-
.../beanio/BeanIOSplitterEncodingTest.java | 156 ++++++++
.../camel/component/es/ElasticsearchProducer.java | 37 +-
.../ElasticsearchProducerClientLifecycleTest.java | 159 ++++++++
.../camel/component/file/watch/file-watch.json | 2 +-
.../src/main/docs/file-watch-component.adoc | 12 +-
.../component/file/watch/FileWatchConstants.java | 3 +-
.../component/file/watch/FileWatchConsumer.java | 14 +-
.../file/watch/FileWatchComponentTest.java | 35 ++
components/camel-file/pom.xml | 6 +
.../camel/component/file/FileOperations.java | 77 ++--
.../camel/component/file/GenericFileProducer.java | 187 ++++++++-
.../file/FileProducerSameFileLockTest.java | 178 +++++++++
.../FtpProducerChecksumFileAlgorithmIT.java | 234 +++++++++++
.../main/docs/google-secret-manager-component.adoc | 12 +-
.../apache/camel/component/ibm/cos/ibm-cos.json | 5 +-
.../src/main/docs/ibm-cos-component.adoc | 6 +-
.../camel/component/ibm/cos/IBMCOSConstants.java | 6 +-
.../camel/component/ibm/cos/IBMCOSProducer.java | 4 +-
.../ibm/cos/IBMCOSProducerBucketHeaderTest.java | 125 ++++++
.../IBMCOSProducerAdditionalOperationsIT.java | 4 +-
.../jgroups/raft/JGroupsRaftComponent.java | 90 +++++
.../jgroups/raft/JGroupsRaftConsumer.java | 9 +-
.../jgroups/raft/JGroupsRaftEndpoint.java | 40 +-
.../jgroups/raft/JGroupsRaftProducer.java | 8 +-
.../JGroupsRaftComponentHandleEndpointsTest.java | 118 ++++++
.../raft/JGroupsRaftNeverStartedConsumerTest.java | 62 +++
.../knative/http/KnativeHttpConsumer.java | 2 +
.../component/knative/http/KnativeHttpTest.java | 82 ++++
.../apache/camel/component/nats/NatsConsumer.java | 98 ++++-
.../nats/NatsConsumerJetStreamPushStopTest.java | 438 +++++++++++++++++++++
.../component/opensearch/OpensearchProducer.java | 37 +-
.../OpensearchProducerClientLifecycleTest.java | 157 ++++++++
.../src/main/docs/opentelemetry2.adoc | 2 +-
.../camel-test-dst/src/main/docs/test-dst.adoc | 77 +++-
.../main/java/org/apache/camel/test/dst/Dst.java | 21 +-
.../java/org/apache/camel/test/dst/DstClock.java | 53 +++
.../org/apache/camel/test/dst/DstExtension.java | 31 +-
.../org/apache/camel/test/dst/DstInstrument.java | 19 +-
.../apache/camel/test/dst/DstInstrumentation.java | 16 +-
.../apache/camel/test/dst/DstAlsoRewriteTest.java | 34 +-
.../apache/camel/test/dst/DstCoreWaitsTest.java | 71 +++-
.../apache/camel/test/dst/DstTimeSourceTest.java | 179 +++++++++
.../camel/impl/engine/DefaultShutdownStrategy.java | 3 +-
.../modules/eips/pages/keyValueRepository.adoc | 10 +
.../processor/ConcurrentRequestsThrottler.java | 11 +-
.../camel/processor/DelayProcessorSupport.java | 5 +-
.../apache/camel/processor/MulticastProcessor.java | 3 +-
.../apache/camel/processor/SamplingThrottler.java | 5 +-
.../camel/processor/TotalRequestsThrottler.java | 13 +-
.../processor/aggregate/AggregateProcessor.java | 5 +-
.../aggregate/OptimisticLockRetryPolicy.java | 4 +-
.../errorhandler/RedeliveryErrorHandler.java | 3 +-
.../processor/errorhandler/RedeliveryPolicy.java | 3 +-
.../FileProducerChecksumOfWrittenFileTest.java | 88 +++++
...AutoDiscoveredKeyValueRepositorySharedTest.java | 101 +++++
.../support/KeyValueAggregationRepositoryTest.java | 28 ++
.../apache/camel/support/DefaultTimeoutMap.java | 3 +-
.../support/KeyValueAggregationRepository.java | 35 +-
.../org/apache/camel/support/MonotonicClock.java | 7 +-
.../startup/DefaultStartupConditionStrategy.java | 3 +-
.../apache/camel/support/task/AbstractTask.java | 4 +-
.../apache/camel/support/task/BackgroundTask.java | 5 +-
.../apache/camel/support/task/ForegroundTask.java | 13 +-
.../task/budget/IterationBoundedBudget.java | 7 +-
.../support/task/budget/TimeBoundedBudget.java | 6 +-
.../throttling/ThrottlingExceptionRoutePolicy.java | 13 +-
.../main/java/org/apache/camel/util/StopWatch.java | 10 +-
.../java/org/apache/camel/util/TimeSource.java | 172 ++++++++
.../camel/util/backoff/BackOffTimerTask.java | 3 +-
.../java/org/apache/camel/util/TimeSourceTest.java | 162 ++++++++
.../camel-tui-source-body-problem-on-open.png | Bin 0 -> 224936 bytes
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 24 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 24 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 67 ++++
.../ROOT/pages/camel-jbang-tui-source-editor.adoc | 11 +-
.../modules/ROOT/pages/key-value-repository.adoc | 10 +
.../ROOT/pages/property-placeholder-functions.adoc | 4 +-
.../modules/ROOT/pages/route-configuration.adoc | 3 +-
docs/user-manual/modules/ROOT/pages/security.adoc | 68 ++--
.../ROOT/pages/using-propertyplaceholder.adoc | 14 +-
.../dsl/FileWatchEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/IBMCOSEndpointBuilderFactory.java | 19 +-
.../dsl/jbang/core/commands/ai/eip-samples.json | 2 +-
.../dsl/jbang/core/commands/tui/SourceChecks.java | 30 +-
.../jbang/core/commands/tui/SourceChecksTest.java | 28 ++
.../camel/dsl/yaml/validator/YamlValidator.java | 34 +-
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 22 ++
108 files changed, 4129 insertions(+), 478 deletions(-)
create mode 100644
components/camel-aws/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisEndpointClientTest.java
copy
components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/{AWS2S3ProducerAclGrantTest.java
=> AWS2S3ProducerMultipartMetadataTest.java} (51%)
copy
components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/dst/{SqsVisibilityDstTest.java
=> SqsRedeliveryDstTest.java} (58%)
create mode 100644
components/camel-beanio/src/test/java/org/apache/camel/dataformat/beanio/BeanIOSplitterEncodingTest.java
create mode 100644
components/camel-elasticsearch/src/test/java/org/apache/camel/component/es/ElasticsearchProducerClientLifecycleTest.java
create mode 100644
components/camel-file/src/test/java/org/apache/camel/component/file/FileProducerSameFileLockTest.java
create mode 100644
components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/integration/FtpProducerChecksumFileAlgorithmIT.java
create mode 100644
components/camel-ibm/camel-ibm-cos/src/test/java/org/apache/camel/component/ibm/cos/IBMCOSProducerBucketHeaderTest.java
create mode 100644
components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftComponentHandleEndpointsTest.java
create mode 100644
components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/JGroupsRaftNeverStartedConsumerTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerJetStreamPushStopTest.java
create mode 100644
components/camel-opensearch/src/test/java/org/apache/camel/component/opensearch/OpensearchProducerClientLifecycleTest.java
create mode 100644
components/camel-test/camel-test-dst/src/test/java/org/apache/camel/test/dst/DstTimeSourceTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/component/file/FileProducerChecksumOfWrittenFileTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregateAutoDiscoveredKeyValueRepositorySharedTest.java
create mode 100644
core/camel-util/src/main/java/org/apache/camel/util/TimeSource.java
create mode 100644
core/camel-util/src/test/java/org/apache/camel/util/TimeSourceTest.java
create mode 100644
docs/user-manual/modules/ROOT/images/jbang/camel-tui-source-body-problem-on-open.png
