This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch fix/CAMEL-25307
in repository https://gitbox.apache.org/repos/asf/camel.git
omit 868a12ad27b4 CAMEL-25307: review - one shared HttpClient for the
request tool, nanoTime for the elapsed time
omit 5e874feafc13 CAMEL-25307: camel-jbang - an HTTP tool group: served
endpoints and a request tool for the selected integration
omit ff7e9f8f86de CAMEL-24834: review - newer features win on merge,
consistent volatile fields, broader status read guard
omit 262434be7410 CAMEL-24834: SQL in the tool group is not limited to
reading (developer tool)
omit 6a3f31341dec CAMEL-24834: load AI tool groups (SQL, tracing,
resilience) from what the selected app has, read-only SQL for local models
add 3e9a8b3b5671 CAMEL-25296: camel-jbang - camel_get_log leaves out stack
traces by default, keeping the error line (#27317)
add 302d1e0bba2f CAMEL-25291: camel-plc4x - fail the exchange when a write
or read cannot be done (#27327)
add df0a84fda895 CAMEL-25295: camel-undertow - match the charset parameter
of the Content-Type case-insensitively (#27326)
add 7b8b5d4cf698 CAMEL-25294: camel-consul - readTimeout and writeTimeout
must set the read and write timeouts of the client (#27325)
add f57419ff40b8 CAMEL-25293: camel-hivemq - the consumer must process the
messages it received before it stops (#27324)
add 37b9750d81ef CAMEL-25292: camel-plc4x - a stopped triggered consumer
must stop its scraper, and the triggered consumer must start (#27323)
add c866afdce9d6 CAMEL-25290: camel-couchdb - the consumer must apply
updates=false, and move past the changes it skips (#27322)
add 657adf3c2e0e CAMEL-25289: camel-iggy - a failed send or poll must not
keep its pooled client, and stopped producers and consumers must close their
clients (#27321)
add ddd0fee0d23e CAMEL-25288: camel-dapr - consumers must only close the
clients they created, and the configuration consumer must take the client of
the started endpoint (#27320)
add d3ade1a0bc18 CAMEL-25287: camel-splunk-hec - the producer must start
without sslContextParameters (#27319)
add ff898996c7b1 CAMEL-25286: camel-consul - cluster view must keep taking
part in the leader election after a failed query or an invalidated session
(#27311)
add f96b728a4d58 CAMEL-25273: camel-kubernetes - consumers must watch
again when the client closes their watch with an error (#27302)
add 05b50436a726 CAMEL-25262: camel-stax - fix xtokenize NPE when used
without properties (#27316)
add 9e192fd3aefa CAMEL-25309: camel-http - a Map or List body says to
marshal it to JSON first (#27331)
add 51cfc77abea1 CAMEL-25321: camel-rest-openapi - client request
validation checks the path parameters too (#27333)
add 6bda4be83495 CAMEL-24831: camel-ai-tool - authorize tool calls with a
component authorizationPolicy, including over MCP (#27332)
add cc5a06b04130 CAMEL-25184: camel-openfga - add the readTuples,
readChanges and expand operations (#27195)
add d3ed374d051c CAMEL-25187: camel-support - accept media ranges such as
application/* in the Accept header (#27315)
add 15f193253391 CAMEL-25322: camel-bean - a missing Map key says the Map
has no such key and lists its keys (#27334)
add 11d2f7e95205 CAMEL-24834: camel-jbang - load AI tool groups (SQL,
tracing, resilience) from what the selected integration has (#27318)
add 1b66f167401c CAMEL-25307: camel-jbang - an HTTP tool group: served
endpoints and a request tool for the selected integration
add ea9e00d6a2cf CAMEL-25307: review - one shared HttpClient for the
request tool, nanoTime for the elapsed time
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (868a12ad27b4)
\
N -- N -- N refs/heads/fix/CAMEL-25307 (ea9e00d6a2cf)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../apache/camel/catalog/components/ai-tool.json | 6 +-
.../apache/camel/catalog/components/openfga.json | 105 +++----
.../camel/catalog/docs/ai-tool-component.adoc | 68 +++++
.../camel/catalog/docs/openfga-component.adoc | 87 +++++-
.../camel/catalog/docs/rest-openapi-component.adoc | 4 +
.../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 | 6 +-
.../src/main/docs/ai-tool-component.adoc | 68 +++++
.../component/ai/tool/AiToolConfiguration.java | 21 ++
.../camel/component/ai/tool/AiToolConsumer.java | 67 +++++
.../camel/component/ai/tool/AiToolExecutor.java | 38 ++-
.../camel/component/ai/tool/AiToolResult.java | 13 +
.../tool/AiToolAuthorizationPolicyStartupTest.java | 96 +++++++
.../ai/tool/AiToolAuthorizationPolicyTest.java | 167 +++++++++++
.../AiToolComponentAuthorizationPolicyTest.java | 121 ++++++++
.../agent/LangChain4jAgentProducer.java | 4 +
.../component/mcp/server/McpServerBridge.java | 23 +-
.../component/mcp/server/McpToolCallContext.java | 46 +++
.../component/mcp/server/McpToolCallHandler.java | 17 ++
.../mcp/server/vertx/VertxMcpServerEngine.java | 13 +-
.../VertxMcpStreamableServerTransportProvider.java | 22 +-
.../main/McpServerMainAuthenticationTest.java | 85 ++++++
.../component/openai/McpToolCallExecutor.java | 4 +
.../apache/camel/language/bean/BeanExpression.java | 18 +-
.../consul/ConsulClientConfiguration.java | 4 +-
.../consul/cluster/ConsulClusterView.java | 124 ++++++--
.../ConsulClientConfigurationTimeoutTest.java | 87 ++++++
.../cluster/ConsulClusterViewRecoveryTest.java | 318 +++++++++++++++++++++
.../camel/component/couchdb/CouchDbConsumer.java | 16 +-
.../couchdb/CouchDbConsumerFilterTest.java | 110 +++++++
.../apache/camel/component/dapr/DaprEndpoint.java | 36 +++
.../dapr/consumer/DaprConfigurationConsumer.java | 39 ++-
.../dapr/consumer/DaprPubSubConsumer.java | 10 +-
.../dapr/DaprEndpointClientOwnershipTest.java | 91 ++++++
.../consumer/DaprConfigurationConsumerTest.java | 11 +-
.../consumer/DaprConsumerSharedClientTest.java | 142 +++++++++
.../dapr/consumer/DaprPubSubConsumerTest.java | 4 +-
.../camel/component/hivemq/HiveMQConsumer.java | 3 +-
.../component/hivemq/HiveMQConsumerStopTest.java | 183 ++++++++++++
.../apache/camel/component/http/HttpProducer.java | 26 +-
...ctionTest.java => HttpProducerMapBodyTest.java} | 51 ++--
components/camel-iggy/pom.xml | 6 +
.../camel/component/iggy/IggyConfiguration.java | 2 +-
.../apache/camel/component/iggy/IggyConsumer.java | 13 +-
.../camel/component/iggy/IggyFetchRecords.java | 91 +++---
.../apache/camel/component/iggy/IggyProducer.java | 55 +++-
.../iggy/client/IggyClientConnectionPool.java | 22 ++
.../component/iggy/client/IggyClientFactory.java | 8 +
.../camel/component/iggy/IggyMockClientTest.java | 183 ++++++++++++
.../component/jetty/rest/RestJettyAcceptTest.java | 24 ++
.../jetty/rest/RestJettyContentTypeTest.java | 13 +
.../component/kubernetes/KubernetesHelper.java | 68 +++++
.../config_maps/KubernetesConfigMapsConsumer.java | 8 +-
.../KubernetesCustomResourcesConsumer.java | 13 +-
.../deployments/KubernetesDeploymentsConsumer.java | 8 +-
.../events/KubernetesEventsConsumer.java | 8 +-
.../kubernetes/hpa/KubernetesHPAConsumer.java | 8 +-
.../namespaces/KubernetesNamespacesConsumer.java | 8 +-
.../kubernetes/nodes/KubernetesNodesConsumer.java | 8 +-
.../kubernetes/pods/KubernetesPodsConsumer.java | 8 +-
.../KubernetesReplicationControllersConsumer.java | 9 +-
.../services/KubernetesServicesConsumer.java | 8 +-
.../OpenshiftDeploymentConfigsConsumer.java | 9 +-
.../KubernetesPodsConsumerWatchClosedTest.java | 144 ++++++++++
.../openfga/OpenFgaComponentConfigurer.java | 18 ++
.../openfga/OpenFgaEndpointConfigurer.java | 18 ++
.../openfga/OpenFgaEndpointUriFactory.java | 5 +-
.../apache/camel/component/openfga/openfga.json | 105 +++----
.../src/main/docs/openfga-component.adoc | 87 +++++-
.../camel/component/openfga/OpenFgaAuthorizer.java | 28 ++
.../component/openfga/OpenFgaConfiguration.java | 49 ++++
.../camel/component/openfga/OpenFgaConstants.java | 10 +
.../camel/component/openfga/OpenFgaEndpoint.java | 37 ++-
.../camel/component/openfga/OpenFgaOperation.java | 16 ++
.../camel/component/openfga/OpenFgaProducer.java | 249 ++++++++++++++++
.../apache/camel/component/openfga/OpenFgaIT.java | 99 +++++++
.../openfga/OpenFgaReadOperationsTest.java | 305 ++++++++++++++++++++
components/camel-plc4x/pom.xml | 6 -
.../camel/component/plc4x/Plc4XConsumer.java | 25 +-
.../component/plc4x/Plc4XPollingConsumer.java | 19 +-
.../camel/component/plc4x/Plc4XProducer.java | 17 +-
.../component/plc4x/Plc4XConsumerStopTest.java | 67 +++++
.../camel/component/plc4x/Plc4XFailureTest.java | 147 ++++++++++
.../src/main/docs/rest-openapi-component.adoc | 4 +
.../rest/openapi/RestOpenApiProcessor.java | 44 +--
.../openapi/validator/DefaultRequestValidator.java | 32 +++
.../openapi/RestOpenApiRequestValidationTest.java | 63 ++++
.../openapi/RestUnmatchedRequestHandlerTest.java | 24 --
.../component/splunkhec/SplunkHECProducer.java | 8 +-
.../splunkhec/SplunkHECProducerHttpTest.java | 100 +++++++
.../springai/chat/AiToolSpecToSpringAi.java | 4 +
.../language/xtokenizer/XMLTokenizeLanguage.java | 2 +-
.../XMLTokenizeLanguageNoPropertiesTest.java | 77 +++++
.../camel/component/undertow/UndertowConsumer.java | 4 +-
.../camel/component/undertow/UndertowHelper.java | 29 +-
.../undertow/UndertowStringBodyCharsetTest.java | 59 ++++
.../language/simple/SimpleSyntaxHintsTest.java | 12 +-
.../apache/camel/support/http/RestUtilTest.java | 38 +++
.../org/apache/camel/support/http/RestUtil.java | 35 ++-
.../DefaultRestClientRequestValidator.java | 3 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_23.adoc | 39 +++
.../modules/ROOT/pages/camel-jbang-mcp.adoc | 9 +-
.../dsl/AiToolComponentBuilderFactory.java | 28 ++
.../dsl/OpenfgaComponentBuilderFactory.java | 59 ++++
.../builder/endpoint/StaticEndpointBuilders.java | 10 +-
.../endpoint/dsl/AiToolEndpointBuilderFactory.java | 50 ++++
.../dsl/OpenFgaEndpointBuilderFactory.java | 98 ++++++-
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 7 +-
.../dsl/jbang/core/commands/ai/LogFileReader.java | 159 ++++++++++-
.../jbang/core/commands/ai/LogFileReaderTest.java | 144 ++++++++++
.../jbang/core/commands/mcp/AuthoringTools.java | 10 +-
.../core/commands/mcp/AuthoringToolsTest.java | 2 +-
.../java/org/apache/camel/dsl/yaml/SplitTest.java | 28 ++
116 files changed, 5186 insertions(+), 401 deletions(-)
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolAuthorizationPolicyStartupTest.java
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolAuthorizationPolicyTest.java
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolComponentAuthorizationPolicyTest.java
create mode 100644
components/camel-ai/camel-mcp-server-api/src/main/java/org/apache/camel/component/mcp/server/McpToolCallContext.java
create mode 100644
components/camel-consul/src/test/java/org/apache/camel/component/consul/ConsulClientConfigurationTimeoutTest.java
create mode 100644
components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusterViewRecoveryTest.java
create mode 100644
components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbConsumerFilterTest.java
create mode 100644
components/camel-dapr/src/test/java/org/apache/camel/component/dapr/DaprEndpointClientOwnershipTest.java
create mode 100644
components/camel-dapr/src/test/java/org/apache/camel/component/dapr/consumer/DaprConsumerSharedClientTest.java
create mode 100644
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQConsumerStopTest.java
copy
components/camel-http/src/test/java/org/apache/camel/component/http/{HttpNoConnectionTest.java
=> HttpProducerMapBodyTest.java} (54%)
create mode 100644
components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyMockClientTest.java
create mode 100644
components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumerWatchClosedTest.java
create mode 100644
components/camel-openfga/src/test/java/org/apache/camel/component/openfga/OpenFgaReadOperationsTest.java
create mode 100644
components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XConsumerStopTest.java
create mode 100644
components/camel-plc4x/src/test/java/org/apache/camel/component/plc4x/Plc4XFailureTest.java
create mode 100644
components/camel-splunk-hec/src/test/java/org/apache/camel/component/splunkhec/SplunkHECProducerHttpTest.java
create mode 100644
components/camel-stax/src/test/java/org/apache/camel/language/xtokenizer/XMLTokenizeLanguageNoPropertiesTest.java
