This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch feature/CAMEL-24961-catalog-body-types-ai
in repository https://gitbox.apache.org/repos/asf/camel.git
from 134daf5e70a9 Merge branch 'feature/CAMEL-24961-catalog-body-types-3'
into feature/CAMEL-24961-catalog-body-types-ai
add f079f97cbf62 CAMEL-25902: camel-netty - add a muteException consumer
option (#28222)
add 536d2e64fea9 CAMEL-25797: camel-pqc - the usage-count and
PENDING_ROTATION key rotation signals now fire (#28094)
add 520bd0e95a11 chore(deps): Bump certifi from 2026.4.22 to 2026.10.19 in
/.github/actions/check-container-upgrade (#28235)
add bb11354d3174 chore(deps-dev): Bump com.github.mwiede:jsch from 2.28.7
to 2.28.8 (#28230)
add ee57734bff0c chore(deps): Bump
org.l2x6.cq:cq-alias-fastinstall-quickly-extension from 4.28.1 to 4.28.3
(#28228)
add be11ef79c181 chore(deps): Bump io.camunda:camunda-client-java from
8.10.2 to 8.10.4 (#28227)
add 7437e9805efb chore(deps): Bump hapi-fhir-core-version from 7.0.1 to
7.0.2 (#28223)
add efec0169e148 CAMEL-25440 / CAMEL-25880: Stabilize port binding and
speed up camel-cxf tests
add 4093897afe49 chore(camel-test-infra-ollama): upgrade
ollama.container.ppc64le to v0.34.1 (#28017)
add ccdc6aa81edb chore(deps): Bump asm-version from 9.11 to 9.11.1
add 0bf90a492b9a chore(deps): Bump org.opensearch:opensearch-testcontainers
add 4b7f8f942860 CAMEL-25781: camel-azure-eventhubs - add 4.22.3 upgrade
guide note to main (#28238)
add d4688eb0bb38 CAMEL-25816: camel-hazelcast - the transacted SEDA
consumer ends its transaction on its own thread (#28205)
add 708a656e368b CAMEL-25915: camel-ftp - Reconnect after a failed poll
with sendNoop=false and a custom poll strategy (#28232)
add d2eff648877e CAMEL-25873: camel-milo - the reconnectTimeout option
sets the delay between connection attempts (#28219)
add 2a8b165e51c8 CAMEL-25813: camel-pulsar - the producer continues the
sequence ids of the broker (#28203)
add 506dc13b6758 CAMEL-25811: camel-keycloak - the consumer reads every
event since the previous poll (#28202)
add fd6bd8013a66 CAMEL-25807: camel-github2 - the commit consumer no
longer loses the commits beyond the newest 100 of a poll (#28199)
add c2962f91b523 CAMEL-25790: camel-google-pubsub - stop pulling once the
consumer stops, also after a restart (#28196)
add 12402a4aec15 chore(deps): Bump com.palantir.javapoet:javapoet from
0.20.0 to 0.22.0 (#28229)
add da0de10c145a chore(deps): Bump dev.toonformat:jtoon from 2.0.7 to
3.0.0 (#28225)
add 549a79fb20ec chore(deps): Bump com.aliyun:kms20160120 from 2.3.0 to
2.3.1 in the aliyun group across 1 directory (#28148)
add 3ef68e407da3 CAMEL-25895: camel-openstack - align the remaining Swift
header constants with the Camel naming convention (#28231)
add 2fefcb707405 CAMEL-25806: camel-jira - the newIssues consumer no
longer loses the issues beyond maxResults of a poll (#28198)
add 6bf60f0cf610 CAMEL-25692: camel-milo - create a refused monitored item
again instead of dropping it (#28212)
add 6e5050a04175 CAMEL-25899: camel-jbang - AI tools: the reload output of
a write keeps the hint of a failure, and a write of a script the routes load
waits for the reload (#28209)
add 41db1dd34e6c CAMEL-25901: camel-jms - docs: a request-reply example in
Java, XML and YAML, and the AI tools say to use InOut instead of setting
JMSReplyTo (#28211)
add 4065a7464c45 CAMEL-25921: camel-tooling-maven - resolve artifacts
cached by Maven 3.10 and do not lose dependencies with preferLocal (#28239)
add a04357c4f4da CAMEL-25900: camel-jbang - AI tools: lead to the jsonpath
filter with resultType java.util.Map for the one element of a list (#28210)
add 9f839f4bcc9d CAMEL-25929: Restore interrupt status in
InterruptedException catch blocks (#28245)
add 8d3b944f02bb CAMEL-25930: camel-file - GenericFilePollingConsumer
should return the polled exchange directly from receive (#28248)
add 0b3c0a429adc CAMEL-25808: camel-mail - do not mark another mail when
the folder had to be opened again during a poll (#28200)
add b7594f06e0b7 CAMEL-25793: camel-paho-mqtt5 - a failed message with
manualAcksEnabled no longer blocks the consumer (#28197)
add 42204f7ce629 CAMEL-25879: camel-infinispan - the key option of the
producer takes precedence over the key header (#28174)
add e6885df7894d CAMEL-25796: camel-pqc - persist the stateful key index
before the signature is published (#28099)
add 8872f75ccd0d Remove PR build for JDK 25 by default to reduce load
add 6f23ea1beb3f CI fork-test: fix concurrency group collision for JDK 25
dispatch
add 33dbcecd2a3b Skip JDK 21 build and rename input to jdk25_only
add bf99380213fc Restore -jdk25 concurrency suffix to prevent PR build
cancellation
add bd49733607f9 CAMEL-25840: camel-hazelcast - the SEDA consumer waits
for its threads before it stops the processor (#28261)
add 50d17f9c2614 CAMEL-25838: camel-iggy - a consumer client created after
a failed poll joins the consumer group (#28259)
add 56aa5f4970a6 CAMEL-25917: camel-undertow - a WebSocket connection
accepted while only a producer served the path is not treated as having passed
a later consumer's custom handlers (#28237)
add 0c1e85c8631c CAMEL-25860: camel-core - fix flaky
PollEnrichTimeoutFileBodyTest
add 9ca5f60d0052 CAMEL-25888: docs - upgrade guide entries for the pubnub
producer channel in 4.22.3 and 4.18.6
add 93d78a5f579b CAMEL-25772: camel-file - leave the kept done files as
they are when the listing was cut (#28255)
add 07d2e7a987bc Upgrade Spring Boot to 4.1.2 and align Spring versions
(#28299)
add 91c0f732343c CAMEL-25771: camel-core - a route checksum and revision,
so tools can tell which routes changed between two runs or after a reload
(#28213)
add c7a63ecb3ec6 CAMEL-24961: camel-catalog - the body a component or data
format needs, and the body it leaves after a step (#28241)
add 55dde649d405 CAMEL-25953: camel-jbang - AI tools: an unchanged write
says so, the log marks records from before the last reload, and a missed edit
shows the file as it is (#28270)
add 720358425bc7 CAMEL-25889: camel-google-mail/drive/calendar/sheets -
create the API client per endpoint credentials instead of one per component
(#28217)
add 50234ed92c59 CAMEL-25985: Expose AI tool JSON arguments and invocation
identifiers (#28295)
add 99d4e71ef236 CAMEL-25665: Fix flaky SmppTRXProducerIT due to race on
server startup (#28244)
add aaf0369de0ee CAMEL-25875: camel-milo - a sessionTimeout configured on
the component reaches its endpoints (#28252)
add 1975e38a2ccc CAMEL-25939: camel-milo - the retry of refused monitored
items follows reconnectTimeout in its docs and tests (#28254)
add d653807aee17 CAMEL-25773: camel-aws-secrets-manager - use one start
time for all CloudTrail lookups of a refresh check (#28256)
add 4e00dfea3b4d CAMEL-25836: camel-jte - compile a template given in the
CamelJteTemplate header once for its content (#28257)
add 0dc6d2087de9 CAMEL-25837: camel-hazelcast - the queue consumer in poll
mode stops without losing items (#28258)
add a4ff25a844c0 CAMEL-25841: camel-xmpp - do not hand out the endpoint of
another participant or user (#28262)
add 3856bca11562 CAMEL-25842: camel-xmpp - the consumer logs in and enters
its room again after its connection was lost (#28263)
add 8e939dc95ed1 CAMEL-25843: camel-hazelcast - the reliable topic
consumer goes on after it lost messages (#28264)
add 3b2931e3ab99 CAMEL-25913: camel-milo - add a dev console that lists
the connections and their refused monitored items (#28272)
add 5aac7df76b83 CAMEL-25697: Fix flaky BonitaAuthFilterConnectionTest
(#28284)
add 5ac45bd37d2b chore(deps): Bump org.mvel:mvel2 from 2.5.4.Final to
2.6.0.Final (#28294)
add 8a0b4da7f4eb chore(deps): Bump com.twilio.sdk:twilio from 13.0.2 to
13.1.0 (#28293)
add 3d74fe29654a chore(deps): Bump tools.jackson:jackson-bom from 3.2.3 to
3.2.4 (#28292)
add 8b0cf36f709d chore(deps): Bump org.jgroups:jgroups from 5.5.7.Final to
5.5.8.Final (#28289)
add 6f428fec7e78 chore(deps): Bump org.apache.mina:mina-core from 2.2.9 to
2.2.10 (#28288)
add 8c3a5febcd75 chore(deps-dev): Bump
com.google.testing.compile:compile-testing from 0.23.0 to 0.24.0 (#28287)
add 6a2f66ddec3e chore(deps): Bump com.aliyun:alibabacloud-oss-v2 from
0.6.0 to 0.6.1 in the aliyun group (#28286)
add 77f024019797 CAMEL-26029: Package scanning of JARs must not include
sibling packages (#28313)
add 014b1c1b26d1 CAMEL-25992: camel-pqc - sign and verify message bodies
over their raw bytes (#28296)
add 481428816a13 CAMEL-25839: camel-kamelet - remove the route of a
Kamelet endpoint that toD discards after use (#28260)
add 48f499f5e991 CAMEL-25705: camel-netty-http - reject an ambiguous
request path when a security constraint is configured (#27945)
add 8314239af1d4 CAMEL-25963: camel-util - speed up compilation of
ArtifactUtils
add b7064881cc29 CAMEL-25984: camel-cometd - CORS filter allows
credentials only for listed origins (#28283)
add c0c69284a8ea CAMEL-25992: camel-pqc - sync the 4.22 and 4.18 upgrade
guides on main (#28332)
add 6899d606d363 CAMEL-25923: camel-core - unmarshal with allowNullBody
keeps the message when the body is null (#28301)
add 3b0c32f0de7c CAMEL-25844: camel-dapr - subscribe again to
configuration changes when the stream ends (#28317)
add d9a95c67223a CAMEL-25849: camel-disruptor - a disruptor-vm consumer
keeps consuming when the CamelContext that first used the queue stops (#28322)
add faa015319ee7 CAMEL-25853: camel-paho, camel-paho-mqtt5, camel-hivemq -
toD publishes to its own topic (#28326)
add 1bc77dcd6774 CAMEL-26027: camel-telegram - concurrent sends through
one endpoint each build their own request (#28311)
add d35571d23f19 CAMEL-26041: camel-bean - a call of equals on the body
says how to compare, not to unmarshal the body (#28315)
add f4ea67114250 CAMEL-25994: camel-undertow - WebSocket: keep the OAuth
validation of a connection per endpoint, like the other security checks (#28297)
add 937f2db3d8c1 CAMEL-25771: camel-jbang - the Routes and Diagram views
show the revision and checksum of a route, and the Source view whether the file
runs as saved (#28220)
add f87b16d93bcc CAMEL-24961: camel-catalog - the body types of
platform-http, rest, ftp, jms, kafka, aws2-sqs, paho-mqtt5, mongodb, the csv,
jacksonXml and yaml data formats, and the languages (#28242)
add 5b3a95b79902 Merge remote-tracking branch 'origin/main' into
feature/CAMEL-24961-catalog-body-types-3
add ac4b0807f4b6 Merge branch 'feature/CAMEL-24961-catalog-body-types-3'
into feature/CAMEL-24961-catalog-body-types-ai
add 6392ce54180b CAMEL-25955: watchesFile ignores JVM options with
wildcards to fix flaky test (#28304)
add ed3d719b379c chore: upgrade guide - the pqc note about signing message
bodies over their bytes is part of 4.22.3
add 255772f0de44 chore: camel-jbang - source editor: a note on a line that
sends to a direct: or seda: endpoint no route consumes (#28342)
add c78e59f0df66 CAMEL-25964: camel-vertx - VertxHelper does not apply
standalone TrustManager from SSLContextParameters (#28305)
add cb73720780f9 CAMEL-25918: camel-as2 - consumers sharing a port use
their own asynchronous MDN settings (#28274)
add 1478bac65753 chore(deps): Bump jackson2-version from 2.22.3 to 2.22.4
(#28290)
add 67e73b3cb425 chore: camel-jbang - source editor: a note for a direct:
or seda: endpoint no route consumes on Java and XML routes too
add 9869dd004979 chore: camel-aws2-step-functions - the operation option
listed the operations of aws2-lambda
add ec5d16cdbf79 chore(ci): use nats 2.15.0 instead of 2.15.1 for ppc64le
add 223ecca4442a CAMEL-25851: camel-paho-mqtt5 - consumers that share a
client each get the messages of their own topic (#28324)
add 7b58ce0cdaf6 CAMEL-25488: camel-jgroups-raft - tests close their
channels and report the state of the nodes when no leader is elected (#28243)
add b649901c4c2b chore(deps): Bump grpc-version from 1.85.0 to 1.85.1
add 36bebb520a63 chore(deps): Bump httpclient-version from 5.6.4 to 5.6.5
add 9aee81df989a CAMEL-25815: camel-nats - the JetStream pull consumer
subscribes again when the server deleted its consumer (#28204)
add adf38d969ea8 CAMEL-25846: camel-tahu - an Edge Node producer connects
again after its route is restarted (#28319)
add a4f2532b4262 CAMEL-25848: camel-quartz - a scheduled resume or start
starts a consumer that the scheduled suspend stopped (#28321)
add d761ff850947 CAMEL-25852: camel-jgroups - an endpoint no longer
disconnects or closes the channel of the component while other endpoints use it
(#28325)
add b1c3c9212a05 chore(deps): Bump the kamelet group with 2 updates
(#28338)
add 330754002072 CAMEL-25694: camel-milo - fix write/call service failures
being reported as success (#27956)
add 694245fae833 CAMEL-25850: camel-jetty - stopping one Jetty server
stops only its own thread pool (#28323)
add dc990927b60e CAMEL-26068: camel-netty-http - Ensure
NettyHttpSecurityConfiguration is copied per endpoint (#28351)
add dfd02e66a4d0 CAMEL-25845: camel-nats - the JetStream push consumer
subscribes again when the server deleted its ephemeral consumer (#28318)
add 78c989ec5182 CAMEL-26105: camel-aws2-athena - take the SQL from the
message body only with useMessageBodyForSql (#28356)
add dd8c3d27b947 CAMEL-24961: camel-yaml-dsl-validator - the body walks
read the body types of the catalog instead of their own tables (#28246)
add 5ceb50c72874 CAMEL-24961: docs - the component, data format and
language pages show the body types in a Message Body section (#28247)
add a7c76d3a2719 Merge remote-tracking branch 'origin/main' into
feature/CAMEL-24961-catalog-body-types-ai
No new revisions were added by this update.
Summary of changes:
.../check-container-upgrade/requirements.txt | 6 +-
.github/workflows/pr-build-main.yml | 111 +-
.mvn/extensions.xml | 2 +-
.../apache/camel/catalog/components/ai-tool.json | 66 +-
.../org/apache/camel/catalog/components/as2.json | 8 +-
.../camel/catalog/components/aws2-athena.json | 88 +-
.../catalog/components/aws2-step-functions.json | 6 +-
.../camel/catalog/components/hazelcast-seda.json | 2 +-
.../org/apache/camel/catalog/components/imap.json | 4 +-
.../org/apache/camel/catalog/components/imaps.json | 4 +-
.../catalog/components/infinispan-embedded.json | 4 +-
.../camel/catalog/components/infinispan.json | 4 +-
.../org/apache/camel/catalog/components/jira.json | 2 +-
.../apache/camel/catalog/components/keycloak.json | 4 +-
.../camel/catalog/components/milo-browse.json | 38 +-
.../camel/catalog/components/milo-client.json | 38 +-
.../camel/catalog/components/netty-http.json | 4 +-
.../org/apache/camel/catalog/components/netty.json | 264 ++---
.../camel/catalog/components/openstack-swift.json | 8 +-
.../camel/catalog/components/paho-mqtt5.json | 4 +-
.../org/apache/camel/catalog/components/pop3.json | 4 +-
.../org/apache/camel/catalog/components/pop3s.json | 4 +-
.../apache/camel/catalog/components/pulsar.json | 4 +-
.../org/apache/camel/catalog/components/smtp.json | 4 +-
.../org/apache/camel/catalog/components/smtps.json | 4 +-
.../apache/camel/catalog/dev-consoles-openapi.json | 94 ++
.../apache/camel/catalog/dev-consoles.properties | 1 +
.../camel/catalog/dev-consoles/milo-client.json | 78 ++
.../camel/catalog/dev-consoles/route-dump.json | 4 +
.../catalog/dev-consoles/route-structure.json | 4 +
.../apache/camel/catalog/dev-consoles/route.json | 8 +
.../camel/catalog/docs/ai-tool-component.adoc | 56 +
.../apache/camel/catalog/docs/as2-component.adoc | 8 +
.../camel/catalog/docs/aws2-athena-component.adoc | 120 ++-
.../apache/camel/catalog/docs/dapr-component.adoc | 2 +
.../camel/catalog/docs/google-mail-component.adoc | 2 +
.../catalog/docs/hazelcast-topic-component.adoc | 5 +
.../camel/catalog/docs/infinispan-component.adoc | 19 +
.../docs/infinispan-embedded-component.adoc | 19 +
.../apache/camel/catalog/docs/jira-component.adoc | 8 +
.../apache/camel/catalog/docs/jms-component.adoc | 92 +-
.../apache/camel/catalog/docs/jte-component.adoc | 3 +
.../camel/catalog/docs/keycloak-consumer.adoc | 11 +-
.../camel/catalog/docs/milo-client-component.adoc | 18 +-
.../apache/camel/catalog/docs/nats-component.adoc | 30 +
.../apache/camel/catalog/docs/netty-component.adoc | 5 +
.../camel/catalog/docs/paho-mqtt5-component.adoc | 27 +
.../apache/camel/catalog/docs/pqc-component.adoc | 2 +-
.../camel/catalog/docs/pqc-key-lifecycle.adoc | 25 +-
.../camel/catalog/docs/pulsar-component.adoc | 8 +
.../camel/catalog/docs/tahu-edge-component.adoc | 4 +
.../apache/camel/catalog/docs/unmarshal-eip.adoc | 3 +-
.../apache/camel/catalog/docs/xmpp-component.adoc | 7 +
.../ai/tool/AiToolComponentConfigurer.java | 6 +
.../ai/tool/AiToolConfigurationConfigurer.java | 6 +
.../ai/tool/AiToolEndpointConfigurer.java | 6 +
.../ai/tool/AiToolEndpointUriFactory.java | 3 +-
.../apache/camel/component/ai/tool/ai-tool.json | 66 +-
.../src/main/docs/ai-tool-component.adoc | 56 +
.../component/ai/tool/AiToolConfiguration.java | 15 +
.../camel/component/ai/tool/AiToolConstants.java | 38 +
.../camel/component/ai/tool/AiToolEndpoint.java | 1 +
.../camel/component/ai/tool/AiToolExecutor.java | 72 +-
.../component/ai/tool/AiToolArgumentsBodyTest.java | 194 ++++
.../agent/LangChain4jAgentProducer.java | 21 +-
...ngChain4jAgentExecuteToolsConcurrentlyTest.java | 43 +-
.../component/openai/McpToolCallExecutor.java | 26 +-
.../component/openai/OpenAIResponsesProducer.java | 7 +-
.../component/openai/McpToolCallExecutorTest.java | 33 +-
.../component/openai/OpenAIResponsesMockTest.java | 30 +
.../component/as2/api/AS2ServerConnection.java | 90 +-
.../AS2ConsumerConfigurationMdnSettingsTest.java | 91 ++
.../org/apache/camel/component/as2/as2.json | 8 +-
.../src/main/docs/as2-component.adoc | 8 +
.../camel/component/as2/AS2Configuration.java | 13 +-
.../apache/camel/component/as2/AS2Consumer.java | 28 +-
.../AS2ServerTwoConsumerAsyncMdnSettingsTest.java | 170 +++
.../vault/CloudTrailReloadTriggerTask.java | 47 +-
.../CloudTrailReloadTriggerTaskLookupTest.java | 57 +-
.../aws2/athena/Athena2ComponentConfigurer.java | 6 +
.../aws2/athena/Athena2EndpointConfigurer.java | 6 +
.../aws2/athena/Athena2EndpointUriFactory.java | 3 +-
.../camel/component/aws2/athena/aws2-athena.json | 88 +-
.../src/main/docs/aws2-athena-component.adoc | 120 ++-
.../aws2/athena/Athena2Configuration.java | 29 +-
.../component/aws2/athena/Athena2Constants.java | 4 +-
.../component/aws2/athena/Athena2Producer.java | 18 +-
.../aws2/athena/AmazonAthenaClientMock.java | 10 +
.../athena/Athena2ProducerQueryStringTest.java | 158 +++
.../athena/AthenaComponentConfigurationTest.java | 18 +
.../component/aws2/athena/AthenaComponentTest.java | 2 +-
.../component/aws2/athena/AthenaEndpointTest.java | 3 +
.../integration/AthenaComponentManualIT.java | 38 +-
.../aws2/kinesis/KclKinesis2Consumer.java | 1 +
.../aws2/stepfunctions/aws2-step-functions.json | 6 +-
.../stepfunctions/StepFunctions2Configuration.java | 2 +-
.../stepfunctions/StepFunctions2Constants.java | 2 +-
.../org/apache/camel/component/bean/BeanInfo.java | 22 +-
.../apache/camel/language/bean/BeanExpression.java | 32 +-
.../bonita/api/BonitaAuthFilterConnectionTest.java | 2 +-
.../camel/component/cometd/CometdComponent.java | 22 +-
.../cometd/CometdCrossOriginFilterTest.java | 131 +++
.../camel/component/cxf/common/CXFTestSupport.java | 54 +-
.../camel/component/cxf/Camel1145RouteTest.java | 10 +-
.../component/cxf/CxfCustomerStartStopTest.java | 14 +-
.../camel/component/cxf/RouteBuilderCxfTracer.java | 3 +-
components/camel-cxf/pom.xml | 4 +
.../camel-dapr/src/main/docs/dapr-component.adoc | 2 +
.../dapr/consumer/DaprConfigurationConsumer.java | 24 +-
.../consumer/DaprConfigurationConsumerTest.java | 49 +
.../component/disruptor/DisruptorReference.java | 56 +-
.../vm/DisruptorVmFirstContextStopTest.java | 65 ++
.../component/file/GenericFileKeptDoneFiles.java | 12 +-
.../component/file/GenericFilePollingConsumer.java | 52 +-
.../file/GenericFileKeptDoneFilesTest.java | 58 +
.../file/remote/RemoteFileConfiguration.java | 4 +-
.../component/file/remote/RemoteFileConsumer.java | 12 +
.../remote/RemoteFileConsumerSendNoopTest.java | 52 +-
.../integration/FtpConsumerSendNoopFalseIT.java | 46 +-
.../component/github2/consumer/CommitConsumer.java | 33 +-
.../GitHub2CommitConsumerManyNewCommitsTest.java | 179 ++++
.../google/calendar/GoogleCalendarComponent.java | 33 +-
.../google/calendar/GoogleCalendarEndpoint.java | 22 +-
.../stream/GoogleCalendarStreamComponent.java | 31 +-
.../stream/GoogleCalendarStreamEndpoint.java | 22 +-
...GoogleCalendarClientPerEndpointOptionsTest.java | 104 ++
...CalendarStreamClientPerEndpointOptionsTest.java | 109 ++
.../google/drive/GoogleDriveComponent.java | 42 +-
.../google/drive/GoogleDriveEndpoint.java | 22 +-
.../GoogleDriveClientPerEndpointOptionsTest.java | 107 ++
.../src/main/docs/google-mail-component.adoc | 2 +
.../component/google/mail/GoogleMailComponent.java | 63 +-
.../component/google/mail/GoogleMailEndpoint.java | 22 +-
.../mail/stream/GoogleMailStreamComponent.java | 32 +-
.../mail/stream/GoogleMailStreamEndpoint.java | 22 +-
...MailUpdateMessageLabelsDataTypeTransformer.java | 2 +-
.../GoogleMailClientPerEndpointOptionsTest.java | 127 +++
...ogleMailStreamClientPerEndpointOptionsTest.java | 124 +++
.../google/pubsub/GooglePubsubConsumer.java | 50 +-
.../GooglePubsubConsumerStopPullingTest.java | 209 ++++
.../google/sheets/GoogleSheetsComponent.java | 26 +-
.../google/sheets/GoogleSheetsEndpoint.java | 22 +-
.../sheets/stream/GoogleSheetsStreamComponent.java | 24 +-
.../sheets/stream/GoogleSheetsStreamEndpoint.java | 23 +-
.../GoogleSheetsClientPerEndpointOptionsTest.java | 103 ++
...leSheetsStreamClientPerEndpointOptionsTest.java | 109 ++
.../component/hazelcast/seda/hazelcast-seda.json | 2 +-
.../src/main/docs/hazelcast-topic-component.adoc | 5 +
.../listener/CamelReliableMessageListener.java | 99 ++
.../hazelcast/queue/HazelcastQueueConsumer.java | 29 +-
.../hazelcast/seda/HazelcastSedaConfiguration.java | 6 +-
.../hazelcast/seda/HazelcastSedaConsumer.java | 83 +-
.../hazelcast/topic/HazelcastTopicConsumer.java | 8 +-
.../HazelcastQueueConsumerPollStopTest.java | 176 +++
.../HazelcastReliableTopicConsumerLossTest.java | 171 +++
.../hazelcast/HazelcastSedaConsumerStopTest.java | 180 ++++
.../HazelcastSedaTransactedAsyncRouteTest.java | 136 +++
...HazelcastSedaTransactedPooledExchangeTest.java} | 45 +-
.../component/hivemq/HiveMQSendDynamicAware.java | 14 +-
.../camel/component/hivemq/HiveMQToDTwiceTest.java | 143 +++
.../apache/camel/component/iggy/IggyConsumer.java | 31 +
.../apache/camel/component/iggy/IggyEndpoint.java | 8 +
.../camel/component/iggy/IggyFetchRecords.java | 3 +
.../iggy/IggyConsumerRejoinGroupTest.java | 150 +++
.../infinispan/InfinispanConfiguration.java | 3 +-
.../component/infinispan/InfinispanProducer.java | 36 +-
.../infinispan/InfinispanProducerTestSupport.java | 6 +-
.../infinispan/embedded/infinispan-embedded.json | 4 +-
.../main/docs/infinispan-embedded-component.adoc | 19 +
.../component/infinispan/remote/infinispan.json | 4 +-
.../src/main/docs/infinispan-component.adoc | 19 +
.../camel/component/jetty/JettyHttpComponent.java | 46 +-
.../jetty/JettyThreadPoolTwoServersTest.java | 96 ++
.../jgroups/raft/JGroupsRaftAbstractTest.java | 37 +-
.../component/jgroups/raft/RaftNodesState.java | 44 +
.../cluster/JGroupsRaftClusterAbstractTest.java | 81 +-
.../JGroupsRaftClusteredRoutePolicyTest.java | 52 +-
.../raft/cluster/JGroupsRaftMasterTest.java | 58 +-
.../camel/component/jgroups/JGroupsComponent.java | 71 ++
.../camel/component/jgroups/JGroupsConsumer.java | 17 +-
.../camel/component/jgroups/JGroupsEndpoint.java | 58 +-
.../camel/component/jgroups/JGroupsProducer.java | 9 +-
.../JGroupsComponentChannelEndpointsTest.java | 151 +++
.../jgroups/JGroupsEndpointOwnChannelTest.java | 161 +++
.../org/apache/camel/component/jira/jira.json | 2 +-
.../camel-jira/src/main/docs/jira-component.adoc | 8 +
.../apache/camel/component/jira/JiraEndpoint.java | 3 +-
.../jira/consumer/AbstractJiraConsumer.java | 48 +-
.../component/jira/consumer/NewIssuesConsumer.java | 13 +-
...wIssuesConsumerMoreThanMaxResultsCloudTest.java | 65 ++
.../NewIssuesConsumerMoreThanMaxResultsTest.java | 170 +++
.../NewIssuesConsumerShrinkingResultTest.java | 65 ++
.../camel-jms/src/main/docs/jms-component.adoc | 92 +-
.../camel-jte/src/main/docs/jte-component.adoc | 3 +
.../camel/component/jte/JteCodeResolver.java | 8 +-
.../apache/camel/component/jte/JteEndpoint.java | 22 +-
.../jte/JteTemplateFromHeaderCompiledOnceTest.java | 107 ++
.../camel/component/kamelet/KameletComponent.java | 203 +++-
.../camel/component/kamelet/KameletEndpoint.java | 11 +
.../camel/component/kamelet/KameletProducer.java | 4 +-
.../kamelet/KameletRouteChecksumTest.java | 72 ++
.../kamelet/KameletToDRoutesNotKeptTest.java | 325 ++++++
.../apache/camel/component/keycloak/keycloak.json | 4 +-
.../src/main/docs/keycloak-consumer.adoc | 11 +-
.../component/keycloak/KeycloakConfiguration.java | 7 +-
.../camel/component/keycloak/KeycloakConsumer.java | 115 +-
.../KeycloakConsumerMoreThanMaxResultsTest.java | 254 +++++
.../org/apache/camel/component/mail/imap.json | 4 +-
.../org/apache/camel/component/mail/imaps.json | 4 +-
.../org/apache/camel/component/mail/pop3.json | 4 +-
.../org/apache/camel/component/mail/pop3s.json | 4 +-
.../org/apache/camel/component/mail/smtp.json | 4 +-
.../org/apache/camel/component/mail/smtps.json | 4 +-
.../camel/component/mail/MailConfiguration.java | 5 +-
.../apache/camel/component/mail/MailConsumer.java | 135 ++-
.../mail/MailConsumerBatchFolderOpenTest.java | 138 +++
.../mail/MailConsumerFolderReopenedTest.java | 261 +++++
.../mail/MailConsumerMailToCommitTest.java | 148 +++
.../milo/browse/MiloBrowseComponentConfigurer.java | 6 +
.../milo/browse/MiloBrowseEndpointConfigurer.java | 6 +
.../milo/browse/MiloBrowseEndpointUriFactory.java | 3 +-
.../milo/client/MiloClientComponentConfigurer.java | 6 +
.../milo/client/MiloClientEndpointConfigurer.java | 6 +
.../milo/client/MiloClientEndpointUriFactory.java | 3 +-
.../camel/component/milo/browse/milo-browse.json | 38 +-
.../camel/component/milo/client/milo-client.json | 38 +-
.../org/apache/camel/dev-console/milo-client.json | 78 ++
.../org/apache/camel/dev-console/milo-client | 2 +
.../org/apache/camel/dev-consoles.properties | 7 +
.../src/main/docs/milo-client-component.adoc | 18 +-
.../component/milo/browse/MiloBrowseComponent.java | 4 +-
.../component/milo/client/MiloClientComponent.java | 5 +-
.../milo/client/MiloClientConfiguration.java | 25 +-
.../milo/client/MiloClientConnection.java | 40 +-
.../component/milo/client/MiloClientConsumer.java | 7 +
.../milo/client/MiloClientDevConsole.java | 133 +++
.../milo/client/internal/SubscriptionManager.java | 240 ++++-
.../component/milo/CommunicationLossTest.java | 204 ++--
.../component/milo/MiloClientDevConsoleTest.java | 588 ++++++++++
.../component/milo/MonitorItemLifecycleTest.java | 16 +-
.../component/milo/MonitoredItemRetryTest.java | 272 +++++
.../milo/ReconnectTimeoutConfigurationTest.java | 96 ++
.../milo/SessionTimeoutConfigurationTest.java | 58 +
.../org/apache/camel/component/milo/TcpRelay.java | 111 ++
.../camel/component/milo/call/CallClientTest.java | 15 +
.../client/MiloClientProducerWriteFailureTest.java | 221 ++++
...ubscriptionManagerExceptionPropagationTest.java | 203 ++++
.../camel-nats/src/main/docs/nats-component.adoc | 30 +
.../camel/component/nats/DefaultNatsManualAck.java | 6 +-
.../apache/camel/component/nats/NatsConsumer.java | 276 ++++-
.../nats/NatsJetStreamPushConsumerKeeper.java | 393 +++++++
.../nats/NatsConsumerPullConsumerDeletedTest.java | 421 ++++++++
.../nats/NatsConsumerPullConsumerGoneTest.java | 263 +++++
.../nats/NatsConsumerPushConsumerDeletedTest.java | 866 +++++++++++++++
.../NatsJetstreamConsumerPullDeletedIT.java | 107 ++
.../netty/http/NettyHttpComponentConfigurer.java | 6 -
.../netty/http/NettyHttpEndpointConfigurer.java | 6 -
.../camel/component/netty/http/netty-http.json | 4 +-
.../component/netty/http/NettyHttpComponent.java | 19 +-
.../netty/http/NettyHttpConfiguration.java | 14 -
.../netty/http/NettyHttpSecurityConfiguration.java | 16 +-
.../http/handlers/HttpServerChannelHandler.java | 101 +-
...NettyHttpBasicAuthConstraintDotSegmentTest.java | 141 +++
...ettyHttpBasicAuthConstraintRootContextTest.java | 114 ++
...ettyHttpComponentMuteExceptionDisabledTest.java | 61 ++
.../NettyHttpSharedSecurityConfigurationTest.java | 116 ++
.../HttpServerChannelHandlerDotSegmentTest.java | 71 ++
.../component/netty/NettyComponentConfigurer.java | 6 +
.../netty/NettyConfigurationConfigurer.java | 6 +
.../component/netty/NettyEndpointConfigurer.java | 6 +
.../component/netty/NettyEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/netty/netty.json | 264 ++---
.../camel-netty/src/main/docs/netty-component.adoc | 5 +
.../camel/component/netty/NettyConfiguration.java | 16 +
.../netty/handlers/ServerChannelHandler.java | 17 +-
.../component/netty/NettyMuteExceptionTest.java | 175 +++
.../NettyTcpWithInOutUsingPlainSocketTest.java | 2 +-
.../component/openstack/swift/openstack-swift.json | 8 +-
.../component/openstack/swift/SwiftConstants.java | 16 +-
.../openstack/swift/ContainerProducerTest.java | 111 ++
components/camel-paho-mqtt5/pom.xml | 12 +
.../camel/component/paho/mqtt5/paho-mqtt5.json | 4 +-
.../src/main/docs/paho-mqtt5-component.adoc | 27 +
.../paho/mqtt5/PahoMqtt5ClientCallback.java | 224 ++++
.../paho/mqtt5/PahoMqtt5Configuration.java | 7 +-
.../component/paho/mqtt5/PahoMqtt5Consumer.java | 285 ++++-
.../paho/mqtt5/PahoMqtt5SendDynamicAware.java | 15 +-
.../mqtt5/PahoMqtt5ClientCallbackMatchesTest.java | 77 ++
.../paho/mqtt5/PahoMqtt5ManualAcksFailureTest.java | 332 ++++++
.../mqtt5/PahoMqtt5SharedClientConsumersTest.java | 234 ++++
.../mqtt5/PahoMqtt5SharedClientReconnectTest.java | 65 ++
.../paho/mqtt5/PahoMqtt5ToDTwiceTest.java | 93 ++
.../camel/component/paho/PahoClientCallback.java | 214 ++++
.../apache/camel/component/paho/PahoConsumer.java | 102 +-
.../camel/component/paho/PahoSendDynamicAware.java | 15 +-
.../paho/PahoClientCallbackMatchesTest.java | 77 ++
.../paho/PahoSharedClientConsumersTest.java | 243 +++++
.../paho/PahoSharedClientReconnectTest.java | 66 ++
.../camel/component/paho/PahoToDTwiceTest.java | 93 ++
.../camel-pqc/src/main/docs/pqc-component.adoc | 2 +-
.../camel-pqc/src/main/docs/pqc-key-lifecycle.adoc | 25 +-
.../apache/camel/component/pqc/PQCProducer.java | 241 ++++-
.../camel/component/pqc/lifecycle/KeyMetadata.java | 7 +
.../pqc/lifecycle/KeyRotationScheduler.java | 18 +-
.../component/pqc/PQCBinaryBodySignatureTest.java | 210 ++++
.../component/pqc/PQCFileBodySignatureTest.java | 247 +++++
.../pqc/PQCStatefulKeyPersistOrderTest.java | 138 +++
.../pqc/lifecycle/KeyRotationSignalsTest.java | 159 +++
.../org/apache/camel/component/pulsar/pulsar.json | 4 +-
.../src/main/docs/pulsar-component.adoc | 8 +
.../component/pulsar/PulsarConfiguration.java | 10 +-
.../camel/component/pulsar/PulsarProducer.java | 8 +-
.../PulsarProducerInitialSequenceIdTest.java | 145 +++
.../routepolicy/quartz/ScheduledRoutePolicy.java | 76 +-
...duledRoutePolicyNonSuspendableConsumerTest.java | 271 +++++
.../camel-salesforce-maven-plugin/pom.xml | 2 +-
.../smpp/integration/SmppTRXProducerIT.java | 47 +-
.../springai/chat/AiToolSpecToSpringAi.java | 3 +-
.../springai/chat/AiToolInvocationTest.java | 78 ++
.../src/main/docs/tahu-edge-component.adoc | 4 +
.../camel/component/tahu/TahuEdgeProducer.java | 145 ++-
.../component/tahu/handlers/TahuEdgeClient.java | 12 +-
.../camel/component/tahu/FakeMqttBroker.java | 168 +++
.../tahu/TahuEdgeProducerRestartTest.java | 249 +++++
.../telegram/service/OutgoingMessageHandler.java | 8 +-
.../telegram/service/TelegramHandlerRegistry.java | 2 +-
.../telegram/service/TelegramMessageHandler.java | 17 +-
.../service/TelegramServiceRestBotAPIAdapter.java | 58 +-
.../telegram/TelegramProducerConcurrentTest.java | 100 ++
.../undertow/handlers/CamelWebSocketHandler.java | 63 +-
...roviderWebSocketConsumerHandlersWindowTest.java | 170 +++
.../UndertowWsOAuthProfileConsumerChangeTest.java | 169 +++
.../UndertowWsOAuthProfileConsumerWindowTest.java | 4 +-
.../ws/UndertowWsSecurityWithoutProviderTest.java | 12 +-
components/camel-vertx/camel-vertx-common/pom.xml | 12 +
.../camel/component/vertx/common/VertxHelper.java | 375 +++----
.../component/vertx/common/VertxHelperTest.java | 132 +++
.../src/test/resources/jsse}/truststore.jks | Bin
components/camel-xmpp/pom.xml | 6 +
.../camel-xmpp/src/main/docs/xmpp-component.adoc | 7 +
.../apache/camel/component/xmpp/XmppComponent.java | 166 ++-
.../apache/camel/component/xmpp/XmppConsumer.java | 120 ++-
.../camel/component/xmpp/XmppDirectProducer.java | 22 +-
.../apache/camel/component/xmpp/XmppEndpoint.java | 126 ++-
.../component/xmpp/XmppGroupChatProducer.java | 34 +-
.../component/xmpp/XmppPrivateChatProducer.java | 17 +-
.../camel/component/xmpp/XmppPubSubProducer.java | 20 +-
.../camel/component/xmpp/FakeXmppServer.java | 305 ++++++
.../xmpp/XmppComponentEndpointPerUriTest.java | 71 ++
.../xmpp/XmppConsumerConnectionRaceTest.java | 113 ++
.../component/xmpp/XmppConsumerReconnectTest.java | 124 +++
.../xmpp/XmppConsumerSmackReconnectTest.java | 111 ++
.../component/xmpp/XmppSharedConnectionTest.java | 289 +++++
.../src/main/java/org/apache/camel/NamedRoute.java | 15 +
.../src/main/java/org/apache/camel/Route.java | 28 +
.../apache/camel/spi/ModelChecksumGenerator.java | 53 +
.../camel/impl/engine/AbstractCamelContext.java | 52 +
.../org/apache/camel/impl/engine/DefaultRoute.java | 18 +
.../org/apache/camel/impl/engine/RouteService.java | 5 +
.../org/apache/camel/dev-console/route-dump.json | 4 +
.../apache/camel/dev-console/route-structure.json | 4 +
.../org/apache/camel/dev-console/route.json | 8 +
.../apache/camel/impl/console/RouteDevConsole.java | 8 +-
.../camel/impl/console/RouteDumpDevConsole.java | 7 +-
.../impl/console/RouteStructureDevConsole.java | 7 +-
.../impl/console/RouteChecksumDevConsoleTest.java | 76 ++
.../docs/modules/eips/pages/unmarshal-eip.adoc | 3 +-
.../camel/impl/DefaultDumpRoutesStrategy.java | 5 +
.../org/apache/camel/model/RouteDefinition.java | 15 +
.../apache/camel/model/RouteDefinitionHelper.java | 24 +
.../processor/ConcurrentRequestsThrottler.java | 1 +
.../file/FilePollEnrichDynamicFileNameTest.java | 87 ++
.../org/apache/camel/impl/RouteChecksumTest.java | 271 +++++
.../language/simple/SimpleSyntaxHintsTest.java | 35 +-
.../processor/UnmarshalAllowNullBodyTest.java | 110 ++
.../camel/processor/UnmarshalProcessorTest.java | 4 +
.../enricher/PollEnrichTimeoutFileBodyTest.java | 5 +-
.../RouteWatcherReloadChangedRoutesTest.java | 161 +++
.../api/management/mbean/ManagedRouteMBean.java | 6 +
.../camel/management/mbean/ManagedRoute.java | 10 +
.../camel/management/ManagedRouteChecksumTest.java | 59 +
.../camel/support/RouteWatcherReloadStrategy.java | 26 +-
.../support/processor/UnmarshalProcessor.java | 54 +-
.../scan/DefaultPackageScanClassResolver.java | 6 +-
.../DefaultPackageScanClassResolverJarTest.java | 88 ++
.../support/scan/jarfixture/routes/ScanTarget.java | 42 +-
.../routesupport/SiblingPackageClass.java | 43 +-
.../java/org/apache/camel/util/ArtifactUtils.java | 1126 ++++++++++----------
.../org/apache/camel/model-checksum-generator | 2 +
.../apache/camel/xml/LwModelChecksumGenerator.java | 63 ++
.../org/apache/camel/xml/LwModelToXMLDumper.java | 120 ++-
.../camel/xml/LwModelToXMLDumperRawUriTest.java | 52 +
design/headers.adoc | 17 +-
docs/components/modules/ROOT/examples/js/camel.js | 44 +
.../modules/ROOT/partials/body-types.adoc | 21 +
.../ROOT/partials/component-endpoint-headers.adoc | 6 +-
.../dataformats/partials/dataformat-options.adoc | 4 +
.../languages/partials/language-options.adoc | 4 +
.../jbang/camel-tui-diagram-route-revision.png | Bin 0 -> 243251 bytes
.../images/jbang/camel-tui-routes-revision.png | Bin 0 -> 285743 bytes
.../jbang/camel-tui-source-running-as-saved.png | Bin 0 -> 278430 bytes
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 48 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_21.adoc | 15 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 54 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 453 +++++++-
.../modules/ROOT/pages/camel-catalog.adoc | 3 +-
.../ROOT/pages/camel-jbang-diagnostics.adoc | 13 +
.../modules/ROOT/pages/camel-jbang-managing.adoc | 5 +
.../ROOT/pages/camel-jbang-tui-diagram.adoc | 15 +
.../ROOT/pages/camel-jbang-tui-source-editor.adoc | 26 +
.../jbang-commands/camel-jbang-get-route.adoc | 1 +
.../jbang-commands/camel-jbang-top-route.adoc | 1 +
.../modules/ROOT/pages/route-reload.adoc | 16 +
docs/user-manual/modules/ROOT/pages/routes.adoc | 39 +
.../cli/debug/CamelCliDebuggerFactory.java | 1 +
.../dsl/AiToolComponentBuilderFactory.java | 21 +
.../dsl/Aws2AthenaComponentBuilderFactory.java | 30 +-
.../Aws2StepFunctionsComponentBuilderFactory.java | 3 +-
.../component/dsl/ImapComponentBuilderFactory.java | 7 +-
.../dsl/ImapsComponentBuilderFactory.java | 7 +-
.../dsl/InfinispanComponentBuilderFactory.java | 3 +-
.../InfinispanEmbeddedComponentBuilderFactory.java | 3 +-
.../dsl/KeycloakComponentBuilderFactory.java | 3 +-
.../dsl/MiloBrowseComponentBuilderFactory.java | 21 +
.../dsl/MiloClientComponentBuilderFactory.java | 21 +
.../dsl/NettyComponentBuilderFactory.java | 20 +
.../dsl/NettyHttpComponentBuilderFactory.java | 5 +-
.../dsl/PahoMqtt5ComponentBuilderFactory.java | 11 +-
.../component/dsl/Pop3ComponentBuilderFactory.java | 7 +-
.../dsl/Pop3sComponentBuilderFactory.java | 7 +-
.../dsl/PulsarComponentBuilderFactory.java | 4 +-
.../component/dsl/SmtpComponentBuilderFactory.java | 7 +-
.../dsl/SmtpsComponentBuilderFactory.java | 7 +-
.../builder/endpoint/EndpointHeaderBuilders.java | 14 +
.../endpoint/dsl/AS2EndpointBuilderFactory.java | 42 +-
.../endpoint/dsl/AiToolEndpointBuilderFactory.java | 87 ++
.../dsl/Athena2EndpointBuilderFactory.java | 51 +-
.../dsl/HazelcastSedaEndpointBuilderFactory.java | 48 +-
.../InfinispanEmbeddedEndpointBuilderFactory.java | 6 +-
.../InfinispanRemoteEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/JiraEndpointBuilderFactory.java | 8 +-
.../dsl/KeycloakEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/MailEndpointBuilderFactory.java | 14 +-
.../dsl/MiloBrowseEndpointBuilderFactory.java | 36 +
.../dsl/MiloClientEndpointBuilderFactory.java | 108 ++
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 34 +
.../dsl/NettyHttpEndpointBuilderFactory.java | 6 +-
.../dsl/PahoMqtt5EndpointBuilderFactory.java | 22 +-
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 8 +-
.../dsl/StepFunctions2EndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/SwiftEndpointBuilderFactory.java | 28 +-
.../endpoint/EndpointDslRouteChecksumTest.java | 55 +
.../META-INF/camel-jbang-commands-metadata.json | 4 +-
.../jbang/core/commands/TransformJavaRoutes.java | 9 +
.../commands/action/CamelRouteStructureAction.java | 6 +
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 211 +++-
.../dsl/jbang/core/commands/ai/CatalogDocs.java | 21 +-
.../core/commands/ai/EndpointConsumerChecks.java | 66 +-
.../core/commands/ai/ExpressionEvaluator.java | 16 +
.../dsl/jbang/core/commands/ai/HeaderChecks.java | 20 +-
.../core/commands/ai/IntegrationLauncher.java | 22 +
.../dsl/jbang/core/commands/ai/JsonPathChecks.java | 61 +-
.../dsl/jbang/core/commands/ai/LogFileReader.java | 2 +-
.../dsl/jbang/core/commands/ai/ModelChecks.java | 13 +
.../dsl/jbang/core/commands/ai/ReloadOutcome.java | 64 +-
.../jbang/core/commands/catalog/CatalogDoc.java | 41 +
.../core/commands/process/CamelRouteStatus.java | 16 +
.../jbang/core/commands/process/CamelRouteTop.java | 5 +
.../commands/action/RouteActionJavaSourceTest.java | 56 +
.../core/commands/ai/AuthoringToolsEditTest.java | 29 +-
.../commands/ai/AuthoringToolsLenientTest.java | 54 +
.../jbang/core/commands/ai/AuthoringToolsTest.java | 81 +-
.../jbang/core/commands/ai/CatalogDocsTest.java | 17 +
.../ai/ExpressionEvaluatorLanguageTest.java | 10 +
.../core/commands/ai/IntegrationLauncherTest.java | 17 +
.../jbang/core/commands/ai/JsonPathChecksTest.java | 54 +
.../jbang/core/commands/ai/LogFileReaderTest.java | 19 +
.../jbang/core/commands/ai/ReloadOutcomeTest.java | 47 +
.../ai/SourceValidatorEndpointConsumersTest.java | 82 ++
.../commands/ai/SourceValidatorEndpointTest.java | 36 +
.../core/commands/catalog/CatalogDocTest.java | 22 +
.../commands/process/CamelRouteStatusTest.java | 28 +
.../dsl/jbang/core/commands/mcp/RuntimeTools.java | 8 +-
.../commands/kubernetes/KubernetesPodLogs.java | 9 +-
dsl/camel-jbang/camel-jbang-plugin-tui/AGENTS.md | 2 +-
.../jbang/core/commands/tui/ConsumedEndpoints.java | 155 +++
.../core/commands/tui/DiagramDetailSupport.java | 21 +
.../dsl/jbang/core/commands/tui/RouteInfo.java | 4 +
.../dsl/jbang/core/commands/tui/RoutesTab.java | 26 +-
.../dsl/jbang/core/commands/tui/SourceChecks.java | 181 ++++
.../jbang/core/commands/tui/SourceEditAssist.java | 6 +-
.../jbang/core/commands/tui/SourceRunState.java | 248 +++++
.../dsl/jbang/core/commands/tui/SourceTab.java | 35 +-
.../dsl/jbang/core/commands/tui/SourceViewer.java | 202 +---
.../dsl/jbang/core/commands/tui/StatusParser.java | 3 +
.../src/main/resources/tui/help/diagram.md | 9 +
.../src/main/resources/tui/help/routes.md | 11 +-
.../src/main/resources/tui/help/source.md | 19 +
.../core/commands/tui/RouteChecksumViewsTest.java | 149 +++
.../jbang/core/commands/tui/SourceChecksTest.java | 99 ++
.../core/commands/tui/SourceConsumerNotesTest.java | 274 +++++
.../commands/tui/SourceKameletValidationTest.java | 2 +-
.../core/commands/tui/SourceRunStateTest.java | 232 ++++
.../jbang/core/commands/tui/SourceSizeTest.java | 2 +-
dsl/camel-jbang/camel-launcher/pom.xml | 2 +-
.../camel/main/download/DependencyDownloader.java | 5 +-
parent/pom.xml | 52 +-
.../test/infra/nats/services/container.properties | 2 +
.../infra/ollama/services/container.properties | 2 +-
.../OpenSearchLocalContainerInfraService.java | 18 +-
.../camel/tooling/maven/MavenDownloader.java | 8 +-
.../camel/tooling/maven/MavenDownloaderImpl.java | 77 +-
.../TrackingKeyCompatLocalRepositoryManager.java | 160 +++
.../tooling/maven/MavenDownloaderImplTest.java | 6 +-
.../maven/MavenDownloaderTrackingKeyTest.java | 189 ++++
.../maven/packaging/UpdateArtifactHelper.java | 9 +-
516 files changed, 27708 insertions(+), 3126 deletions(-)
create mode 100644
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/dev-consoles/milo-client.json
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolConstants.java
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolArgumentsBodyTest.java
create mode 100644
components/camel-as2/camel-as2-api/src/test/java/org/apache/camel/component/as2/api/AS2ConsumerConfigurationMdnSettingsTest.java
create mode 100644
components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ServerTwoConsumerAsyncMdnSettingsTest.java
create mode 100644
components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerQueryStringTest.java
create mode 100644
components/camel-cometd/src/test/java/org/apache/camel/component/cometd/CometdCrossOriginFilterTest.java
create mode 100644
components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/vm/DisruptorVmFirstContextStopTest.java
create mode 100644
components/camel-file/src/test/java/org/apache/camel/component/file/GenericFileKeptDoneFilesTest.java
create mode 100644
components/camel-github2/src/test/java/org/apache/camel/component/github2/consumer/GitHub2CommitConsumerManyNewCommitsTest.java
create mode 100644
components/camel-google/camel-google-calendar/src/test/java/org/apache/camel/component/google/calendar/GoogleCalendarClientPerEndpointOptionsTest.java
create mode 100644
components/camel-google/camel-google-calendar/src/test/java/org/apache/camel/component/google/calendar/stream/GoogleCalendarStreamClientPerEndpointOptionsTest.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveClientPerEndpointOptionsTest.java
create mode 100644
components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/GoogleMailClientPerEndpointOptionsTest.java
create mode 100644
components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/stream/GoogleMailStreamClientPerEndpointOptionsTest.java
create mode 100644
components/camel-google/camel-google-pubsub/src/test/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumerStopPullingTest.java
create mode 100644
components/camel-google/camel-google-sheets/src/test/java/org/apache/camel/component/google/sheets/GoogleSheetsClientPerEndpointOptionsTest.java
create mode 100644
components/camel-google/camel-google-sheets/src/test/java/org/apache/camel/component/google/sheets/stream/GoogleSheetsStreamClientPerEndpointOptionsTest.java
create mode 100644
components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/listener/CamelReliableMessageListener.java
create mode 100644
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerPollStopTest.java
create mode 100644
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastReliableTopicConsumerLossTest.java
create mode 100644
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConsumerStopTest.java
create mode 100644
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaTransactedAsyncRouteTest.java
copy
components/{camel-nats/src/main/java/org/apache/camel/component/nats/DefaultNatsManualAck.java
=>
camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaTransactedPooledExchangeTest.java}
(53%)
create mode 100644
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQToDTwiceTest.java
create mode 100644
components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyConsumerRejoinGroupTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyThreadPoolTwoServersTest.java
create mode 100644
components/camel-jgroups-raft/src/test/java/org/apache/camel/component/jgroups/raft/RaftNodesState.java
create mode 100644
components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsComponentChannelEndpointsTest.java
create mode 100644
components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/JGroupsEndpointOwnChannelTest.java
create mode 100644
components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerMoreThanMaxResultsCloudTest.java
create mode 100644
components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerMoreThanMaxResultsTest.java
create mode 100644
components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerShrinkingResultTest.java
create mode 100644
components/camel-jte/src/test/java/org/apache/camel/component/jte/JteTemplateFromHeaderCompiledOnceTest.java
create mode 100644
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletRouteChecksumTest.java
create mode 100644
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletToDRoutesNotKeptTest.java
create mode 100644
components/camel-keycloak/src/test/java/org/apache/camel/component/keycloak/KeycloakConsumerMoreThanMaxResultsTest.java
create mode 100644
components/camel-mail/src/test/java/org/apache/camel/component/mail/MailConsumerBatchFolderOpenTest.java
create mode 100644
components/camel-mail/src/test/java/org/apache/camel/component/mail/MailConsumerFolderReopenedTest.java
create mode 100644
components/camel-mail/src/test/java/org/apache/camel/component/mail/MailConsumerMailToCommitTest.java
create mode 100644
components/camel-milo/src/generated/resources/META-INF/org/apache/camel/dev-console/milo-client.json
create mode 100644
components/camel-milo/src/generated/resources/META-INF/services/org/apache/camel/dev-console/milo-client
create mode 100644
components/camel-milo/src/generated/resources/META-INF/services/org/apache/camel/dev-consoles.properties
create mode 100644
components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientDevConsole.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/MiloClientDevConsoleTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/MonitoredItemRetryTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/ReconnectTimeoutConfigurationTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/SessionTimeoutConfigurationTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/TcpRelay.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/client/MiloClientProducerWriteFailureTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/client/internal/SubscriptionManagerExceptionPropagationTest.java
create mode 100644
components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsJetStreamPushConsumerKeeper.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerPullConsumerDeletedTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerPullConsumerGoneTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerPushConsumerDeletedTest.java
create mode 100644
components/camel-nats/src/test/java/org/apache/camel/component/nats/jetstream/NatsJetstreamConsumerPullDeletedIT.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpBasicAuthConstraintDotSegmentTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpBasicAuthConstraintRootContextTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpComponentMuteExceptionDisabledTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpSharedSecurityConfigurationTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/handlers/HttpServerChannelHandlerDotSegmentTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyMuteExceptionTest.java
create mode 100644
components/camel-paho-mqtt5/src/main/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ClientCallback.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ClientCallbackMatchesTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ManualAcksFailureTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SharedClientConsumersTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5SharedClientReconnectTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ToDTwiceTest.java
create mode 100644
components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoClientCallback.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoClientCallbackMatchesTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoSharedClientConsumersTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoSharedClientReconnectTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDTwiceTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/PQCBinaryBodySignatureTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/PQCFileBodySignatureTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/PQCStatefulKeyPersistOrderTest.java
create mode 100644
components/camel-pqc/src/test/java/org/apache/camel/component/pqc/lifecycle/KeyRotationSignalsTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerInitialSequenceIdTest.java
create mode 100644
components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicyNonSuspendableConsumerTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ai/camel-spring-ai-chat/src/test/java/org/apache/camel/component/springai/chat/AiToolInvocationTest.java
create mode 100644
components/camel-tahu/src/test/java/org/apache/camel/component/tahu/FakeMqttBroker.java
create mode 100644
components/camel-tahu/src/test/java/org/apache/camel/component/tahu/TahuEdgeProducerRestartTest.java
create mode 100644
components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramProducerConcurrentTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/spi/SecurityProviderWebSocketConsumerHandlersWindowTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/ws/UndertowWsOAuthProfileConsumerChangeTest.java
create mode 100644
components/camel-vertx/camel-vertx-common/src/test/java/org/apache/camel/component/vertx/common/VertxHelperTest.java
copy components/{camel-coap/src/test/resources =>
camel-vertx/camel-vertx-common/src/test/resources/jsse}/truststore.jks (100%)
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/FakeXmppServer.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppComponentEndpointPerUriTest.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppConsumerConnectionRaceTest.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppConsumerReconnectTest.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppConsumerSmackReconnectTest.java
create mode 100644
components/camel-xmpp/src/test/java/org/apache/camel/component/xmpp/XmppSharedConnectionTest.java
create mode 100644
core/camel-api/src/main/java/org/apache/camel/spi/ModelChecksumGenerator.java
create mode 100644
core/camel-console/src/test/java/org/apache/camel/impl/console/RouteChecksumDevConsoleTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/component/file/FilePollEnrichDynamicFileNameTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/impl/RouteChecksumTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/UnmarshalAllowNullBodyTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/support/RouteWatcherReloadChangedRoutesTest.java
create mode 100644
core/camel-management/src/test/java/org/apache/camel/management/ManagedRouteChecksumTest.java
create mode 100644
core/camel-support/src/test/java/org/apache/camel/support/scan/DefaultPackageScanClassResolverJarTest.java
copy
components/camel-nats/src/main/java/org/apache/camel/component/nats/DefaultNatsManualAck.java
=>
core/camel-support/src/test/java/org/apache/camel/support/scan/jarfixture/routes/ScanTarget.java
(54%)
copy
components/camel-nats/src/main/java/org/apache/camel/component/nats/DefaultNatsManualAck.java
=>
core/camel-support/src/test/java/org/apache/camel/support/scan/jarfixture/routesupport/SiblingPackageClass.java
(54%)
create mode 100644
core/camel-xml-io/src/generated/resources/META-INF/services/org/apache/camel/model-checksum-generator
create mode 100644
core/camel-xml-io/src/main/java/org/apache/camel/xml/LwModelChecksumGenerator.java
create mode 100644
core/camel-xml-io/src/test/java/org/apache/camel/xml/LwModelToXMLDumperRawUriTest.java
create mode 100644 docs/components/modules/ROOT/partials/body-types.adoc
create mode 100644
docs/user-manual/modules/ROOT/images/jbang/camel-tui-diagram-route-revision.png
create mode 100644
docs/user-manual/modules/ROOT/images/jbang/camel-tui-routes-revision.png
create mode 100644
docs/user-manual/modules/ROOT/images/jbang/camel-tui-source-running-as-saved.png
create mode 100644
dsl/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/EndpointDslRouteChecksumTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/ConsumedEndpoints.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceChecks.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceRunState.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/RouteChecksumViewsTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceChecksTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceConsumerNotesTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/test/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceRunStateTest.java
create mode 100644
tooling/camel-tooling-maven/src/main/java/org/apache/camel/tooling/maven/TrackingKeyCompatLocalRepositoryManager.java
create mode 100644
tooling/camel-tooling-maven/src/test/java/org/apache/camel/tooling/maven/MavenDownloaderTrackingKeyTest.java
