This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26508-netty-transfer-exchange-headers
in repository https://gitbox.apache.org/repos/asf/camel.git
from fbaaf672a638 CAMEL-26508: camel-netty - with transferExchange the
consumer keeps its own connection headers
add b05201d85057 CAMEL-26119: camel-camunda - read a JSON body as bytes or
a stream, and fail the exchange when an operation fails; the JSON uses
camelCase (#28896)
add 7c13a878cbb4 CAMEL-26220: camel-ibm-watson-discovery - manage
com.ibm.cloud:sdk-core 9.24.3, which works with the Gson of Camel, so query no
longer fails with NoClassDefFoundError for $Gson$Types (#28974)
add 869ea9ad41c0 CAMEL-26223: camel-ibm-watson-speech-to-text - close the
audio stream opened for a File, Path or file consumer body (#28972)
add 8d8976c88250 CAMEL-26222: camel-ibm-watsonx-ai - check the elements of
a List of chat messages, and read a bytes or stream body as text for chat,
embedding and rerank (#28971)
add 70e52ddde700 CAMEL-26268: camel-huaweicloud-obs - putObject needs the
bucket name for a File body too (#28967)
add a72119122ec1 CAMEL-26266: camel-huaweicloud-functiongraph - keep the
whole result when it has no body field, and take a JSON object event as bytes,
a stream or a file (#28965)
add 9f59b88c810f CAMEL-26253: camel-google-secret-manager - createSecret
reads the value before it creates the secret, and takes a CreateSecretRequest
with pojoRequest=true (#28963)
add 98d83cd974de CAMEL-26299: camel-azure-eventgrid - build the CloudEvent
with the data format of the body, so sending no longer fails with a
NullPointerException (#28957)
add 421579fe25f9 CAMEL-26262: camel-alibaba-sls - the putLogs examples
build a LogGroup with a bean instead of setting a text body (#28953)
add 7292654a06e9 CAMEL-26260: camel-alibaba-eventbridge - a byte[], stream
or file body is read as the JSON text of the event, instead of failing (#28951)
add 9ff19010c52c CAMEL-26258: camel-alibaba-kms - encrypt encrypts a
stream or a file as its bytes, so binary plaintext is not corrupted (#28949)
add 52c3e9428891 CAMEL-26257: camel-alibaba-fc - invokeFunction sends a
stream or a file as its bytes, so binary data is not corrupted (#28948)
add 88e4b8603214 chore(deps): Bump io.qdrant:client from 1.19.0 to 1.20.0
(#28938)
add 1d2c682d736c chore(deps): Bump web3j-version from 6.0.0 to 6.1.0
(#28937)
add 8bbf76c5b0c1 chore(deps): Bump io.rest-assured:rest-assured from 6.2.0
to 6.3.0 (#28934)
add 59b40d558335 chore(deps-dev): Bump com.icegreen:greenmail from 2.1.14
to 2.1.15 (#28932)
add c90d761ee127 chore(deps): Bump io.camunda:camunda-client-java from
8.10.4 to 8.10.7 (#28930)
add 262ef0d74e82 chore(deps): Bump quarkus-version from 3.40.1 to 3.40.1.1
(#28929)
add 41f7da961d17 CAMEL-26251: camel-google-bigquery - endpoints use the
connectionFactory of the component, a DDL statement gives no body instead of a
NullPointerException, and a body that is not a row fails a grouped exchange
before any row is inserted (#28970)
add b4d63b7d7206 CAMEL-26269: camel-huaweicloud-smn - publish a Map, a
List or a POJO as JSON, and set the message id in CamelHwCloudSmnMessageId
(#28968)
add 4d6de5df2521 CAMEL-26138: camel-http-common - write a chunked or gzip
Map, List, POJO or number reply, keep a form POST body with
disableStreamCache=true, and mapHttpMessageBody=false leaves the body null
(#28911)
add ac892fc4de6b CAMEL-26243: camel-google-sheets - remove
spreadsheets/developerMetadata, sheets and values, the accessors of
sub-resources that failed with a ClassCastException, and document that
splitResult has no effect (#28959)
add acb8f1cfb325 CAMEL-26242: camel-google-mail - remove
messages/attachments, the accessor of the Attachments sub-resource, which
failed with a ClassCastException (#28958)
add f6e08d43062a CAMEL-26247: camel-azure-functions - send the body as
bytes, add the default Content-Type without the headers map, and fail on an
HTTP error status (#28955)
add 2883080b73c9 CAMEL-26261: camel-alibaba-oss - add the includeBody
option, so the consumer can give the stream of an object instead of reading it
into a byte array (#28952)
add 1743bcb5f98f CAMEL-26259: camel-alibaba-mns - send a byte[], stream or
file body as its bytes, give a binary message as bytes, set the message id and
MD5 as headers, and drop receiveMessage from the operations (#28950)
add 6bf110ff054f CAMEL-26252: camel-google-functions - a failed
callFunction fails the exchange, no body fails with an InvalidPayloadException,
and a Map or POJO body is sent as JSON (#28962)
add 9d9c2e836a13 CAMEL-26432: camel-chaos - error status= for netty-http
(#28811)
add d00414c78996 CAMEL-26250: camel-google-vertexai - generateMultimodal
sends a stream, file or bytes body as media, rawPredict reads bytes, stream and
file bodies as text, and the declared headers are applied or deprecated (#28969)
add 4861336aaf4f CAMEL-26267: camel-huaweicloud-iam - read the JSON of
updateUser and updateGroup from bytes, a stream or a file, and write the
results with the field names of the IAM API (#28966)
add f10e145d3b1e CAMEL-26265: camel-huaweicloud-dms - read the JSON
request from bytes, a stream or a file, and fail on a body that is not the
request (#28964)
add 81d06027f606 CAMEL-26249: camel-google-text-to-speech -
pojoRequest=true runs the operation, and listVoices lists all voices unless
languageCode is set (#28961)
add 403acb0ca8c1 CAMEL-26505: camel-jms / camel-sjms - a body that maps to
no JMS message type fails the exchange instead of being sent as an empty
message (#28987)
add d86e316b04a9 CAMEL-26244: camel-google-drive - drive-files/export, and
drive-files/get and drive-revisions/get with alt=media, give the content of the
file as an InputStream, and FileConverterIT uses drive-files/create (#28960)
add e9b27ef1d7b3 CAMEL-26507: camel-vertx - the producer sends a message
without a body as a null body (#28989)
add 07f5c40033ca CAMEL-26504: camel-netty / camel-netty-http - answer or
close when the reply cannot be built or written, honour allowSerializedHeaders
on the reply (#28985)
add 94e7619f147d chore: camel-launcher - run the distribution ITs in
verify, not with -Dquickly, and in the native exe workflow (#28885)
add e4dc3321370c CAMEL-25674: camel-netty-http - hostnameVerification no
longer breaks client certificates on a consumer (#28871)
add b59a37efd89c CAMEL-26490: camel-telemetry, camel-tracing - present the
http.url, url.path and server.address span attributes like camel.uri (#28867)
add cb848054a7b8 chore(deps): Bump endive-version from 1.1.0 to 1.2.0
(#28926)
add 70288e19ee0f chore(deps): Bump
org.apache.maven.plugins:maven-enforcer-plugin from 3.6.3 to 3.7.0 (#28877)
add de836f4af365 CAMEL-26478: camel-util - BoundedExecutorService: a task
must not wait for a permit it holds itself (#28823)
add c5ddcae3d53b CAMEL-26501: camel-aws-bedrock -
aws-bedrock-agent-runtime sends a Map or JsonNode body as JSON (#28981)
add cc1217629ee1 CAMEL-26470: camel-support - PatternHelper: do not
compile a regular expression for a pattern without metacharacters (#28814)
add 065646714889 CAMEL-26221: camel-ibm-watsonx-data - getAllColumns
parses its response with the managed com.ibm.cloud:sdk-core, and updateTable
takes the table patch as JSON text as well as a Map (#28975)
add 64ab57e4dc34 CAMEL-26254: camel-ibm-secrets-manager - getSecret gives
the Secret for every other secret type, createKVSecret takes a JSON object, and
a Map or a POJO is stored as JSON in an arbitrary secret (#28973)
add 980a01202a31 CAMEL-26248: camel-azure-key-vault - deleteSecret sets
the DeletedSecret as the body, and createSecret stores a Map, a List or a POJO
as JSON (#28956)
add 515378b199b8 CAMEL-26246: camel-azure-cosmosdb - parse the JSON of an
item given as text, bytes, a stream or a file, and fail a List body of the item
operations (#28954)
add 343c0492d0ed [JBANG-IT] Adapt container-only tests to run on host
(#28526)
add 6e45319495ca Merge remote-tracking branch 'origin/main' into
CAMEL-26508-netty-transfer-exchange-headers
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 3 +
.github/workflows/camel-launcher-native-exe.yml | 5 +-
.../catalog/components/alibaba-eventbridge.json | 2 +-
.../camel/catalog/components/alibaba-fc.json | 2 +-
.../camel/catalog/components/alibaba-kms.json | 2 +-
.../camel/catalog/components/alibaba-mns.json | 8 +-
.../camel/catalog/components/alibaba-oss.json | 59 +-
.../catalog/components/atmosphere-websocket.json | 2 +-
.../components/aws-bedrock-agent-runtime.json | 2 +-
.../camel/catalog/components/azure-cosmosdb.json | 4 +-
.../camel/catalog/components/azure-eventgrid.json | 2 +-
.../camel/catalog/components/azure-functions.json | 50 +-
.../camel/catalog/components/azure-key-vault.json | 4 +-
.../apache/camel/catalog/components/camunda.json | 4 +-
.../catalog/components/google-bigquery-sql.json | 2 +-
.../camel/catalog/components/google-bigquery.json | 2 +-
.../camel/catalog/components/google-drive.json | 9 +-
.../camel/catalog/components/google-functions.json | 4 +-
.../camel/catalog/components/google-mail.json | 6 +-
.../catalog/components/google-secret-manager.json | 4 +-
.../camel/catalog/components/google-sheets.json | 8 +-
.../catalog/components/google-text-to-speech.json | 6 +-
.../camel/catalog/components/google-vertexai.json | 16 +-
.../camel/catalog/components/hwcloud-dms.json | 2 +-
.../catalog/components/hwcloud-functiongraph.json | 4 +-
.../camel/catalog/components/hwcloud-iam.json | 4 +-
.../camel/catalog/components/hwcloud-smn.json | 4 +-
.../catalog/components/ibm-secrets-manager.json | 4 +-
.../camel/catalog/components/ibm-watsonx-ai.json | 2 +-
.../camel/catalog/components/ibm-watsonx-data.json | 2 +-
.../org/apache/camel/catalog/components/jetty.json | 2 +-
.../apache/camel/catalog/components/servlet.json | 2 +-
.../org/apache/camel/catalog/components/vertx.json | 4 +-
.../docs/alibaba-eventbridge-component.adoc | 11 +-
.../camel/catalog/docs/alibaba-fc-component.adoc | 7 +
.../camel/catalog/docs/alibaba-kms-component.adoc | 8 +
.../camel/catalog/docs/alibaba-mns-component.adoc | 45 +-
.../camel/catalog/docs/alibaba-oss-component.adoc | 39 ++
.../camel/catalog/docs/alibaba-sls-component.adoc | 37 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 7 +-
.../catalog/docs/azure-cosmosdb-component.adoc | 31 +-
.../catalog/docs/azure-eventgrid-component.adoc | 16 +
.../catalog/docs/azure-functions-component.adoc | 17 +
.../catalog/docs/azure-key-vault-component.adoc | 8 +-
.../camel/catalog/docs/camunda-component.adoc | 41 +-
.../org/apache/camel/catalog/docs/chaos.adoc | 35 +-
.../catalog/docs/google-bigquery-component.adoc | 4 +
.../docs/google-bigquery-sql-component.adoc | 1 +
.../camel/catalog/docs/google-drive-component.adoc | 69 +++
.../catalog/docs/google-functions-component.adoc | 12 +
.../docs/google-secret-manager-component.adoc | 40 +-
.../catalog/docs/google-sheets-component.adoc | 9 +
.../docs/google-text-to-speech-component.adoc | 32 +-
.../catalog/docs/google-vertexai-component.adoc | 74 ++-
.../camel/catalog/docs/hwcloud-dms-component.adoc | 6 +-
.../docs/hwcloud-functiongraph-component.adoc | 15 +
.../camel/catalog/docs/hwcloud-iam-component.adoc | 31 +-
.../camel/catalog/docs/hwcloud-smn-component.adoc | 13 +-
.../docs/ibm-secrets-manager-component.adoc | 70 ++-
.../docs/ibm-watson-speech-to-text-component.adoc | 7 +
.../catalog/docs/ibm-watsonx-ai-component.adoc | 13 +
.../catalog/docs/ibm-watsonx-data-component.adoc | 63 ++-
.../apache/camel/catalog/docs/jms-component.adoc | 8 +
.../camel/catalog/docs/netty-http-component.adoc | 11 +
.../apache/camel/catalog/docs/sjms-component.adoc | 3 +-
.../apache/camel/catalog/docs/sjms2-component.adoc | 3 +-
.../apache/camel/catalog/docs/vertx-component.adoc | 3 +-
.../alibaba/eventbridge/alibaba-eventbridge.json | 2 +-
.../main/docs/alibaba-eventbridge-component.adoc | 11 +-
.../eventbridge/AlibabaEventBridgeEndpoint.java | 16 +-
.../eventbridge/AlibabaEventBridgeUtils.java | 42 +-
.../alibaba/eventbridge/PutEventsBodyTest.java | 205 +++++++
.../camel/component/alibaba/fc/alibaba-fc.json | 2 +-
.../src/main/docs/alibaba-fc-component.adoc | 7 +
.../camel/component/alibaba/fc/FCEndpoint.java | 8 +-
.../apache/camel/component/alibaba/fc/FCUtils.java | 7 +-
.../alibaba/fc/InvokeFunctionPayloadTest.java | 162 ++++++
.../camel/component/alibaba/kms/alibaba-kms.json | 2 +-
.../src/main/docs/alibaba-kms-component.adoc | 8 +
.../camel/component/alibaba/kms/KMSEndpoint.java | 9 +-
.../camel/component/alibaba/kms/KMSUtils.java | 14 +-
.../alibaba/kms/EncryptPlaintextTest.java | 170 ++++++
.../camel/component/alibaba/mns/alibaba-mns.json | 8 +-
.../src/main/docs/alibaba-mns-component.adoc | 45 +-
.../camel/component/alibaba/mns/MNSConsumer.java | 3 +-
.../camel/component/alibaba/mns/MNSEndpoint.java | 27 +-
.../camel/component/alibaba/mns/MNSProducer.java | 16 +-
.../camel/component/alibaba/mns/MNSUtils.java | 48 ++
.../component/alibaba/mns/MNSConsumerBodyTest.java | 118 ++++
.../component/alibaba/mns/MNSProducerBodyTest.java | 220 ++++++++
.../mns/MNSProducerResponseHeadersTest.java | 135 +++++
.../mns/MNSReceiveMessageOperationTest.java | 104 ++++
.../alibaba/oss/OSSEndpointConfigurer.java | 6 +
.../alibaba/oss/OSSEndpointUriFactory.java | 3 +-
.../camel/component/alibaba/oss/alibaba-oss.json | 59 +-
.../src/main/docs/alibaba-oss-component.adoc | 39 ++
.../camel/component/alibaba/oss/OSSConsumer.java | 53 +-
.../camel/component/alibaba/oss/OSSEndpoint.java | 21 +-
.../camel/component/alibaba/oss/OSSUtils.java | 37 +-
.../alibaba/oss/OSSConsumerIncludeBodyTest.java | 255 +++++++++
.../src/main/docs/alibaba-sls-component.adoc | 37 +-
.../alibaba/sls/PutLogsDocExampleTest.java | 129 +++++
.../atmosphere/websocket/atmosphere-websocket.json | 2 +-
.../agentruntime/aws-bedrock-agent-runtime.json | 2 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 7 +-
.../component/aws2/bedrock/BedrockBodyHelper.java | 52 ++
.../agentruntime/BedrockAgentRuntimeEndpoint.java | 9 +-
.../agentruntime/BedrockAgentRuntimeProducer.java | 22 +-
.../aws2/bedrock/runtime/BedrockProducer.java | 12 +-
...BedrockAgentRuntimeProducerInvokeAgentTest.java | 26 +
.../BedrockAgentRuntimeProducerInvokeFlowTest.java | 24 +
.../BedrockAgentRuntimeProducerRetrieveTest.java | 46 ++
.../component/azure/cosmosdb/azure-cosmosdb.json | 4 +-
.../src/main/docs/azure-cosmosdb-component.adoc | 31 +-
.../CosmosDbConfigurationOptionsProxy.java | 102 +++-
.../component/azure/cosmosdb/CosmosDbEndpoint.java | 31 +-
.../cosmosdb/CosmosDbProducerItemBodyTest.java | 278 ++++++++++
.../component/azure/eventgrid/azure-eventgrid.json | 2 +-
.../src/main/docs/azure-eventgrid-component.adoc | 16 +
.../azure/eventgrid/EventGridEndpoint.java | 14 +-
.../azure/eventgrid/EventGridProducer.java | 87 ++-
.../azure/eventgrid/EventGridProducerTest.java | 294 ++++++++++
.../camel-azure/camel-azure-functions/pom.xml | 5 +
.../functions/FunctionsComponentConfigurer.java | 6 +
.../functions/FunctionsEndpointConfigurer.java | 6 +
.../functions/FunctionsEndpointUriFactory.java | 3 +-
.../component/azure/functions/azure-functions.json | 50 +-
.../src/main/docs/azure-functions-component.adoc | 17 +
.../azure/functions/FunctionsConfiguration.java | 14 +
.../azure/functions/FunctionsEndpoint.java | 24 +-
.../azure/functions/FunctionsProducer.java | 43 +-
.../client/FunctionsInvocationClient.java | 36 +-
.../functions/FunctionsProducerInvokeTest.java | 316 +++++++++++
.../component/azure/key/vault/azure-key-vault.json | 4 +-
.../src/main/docs/azure-key-vault-component.adoc | 8 +-
.../azure/key/vault/KeyVaultEndpoint.java | 23 +-
.../azure/key/vault/KeyVaultProducer.java | 75 ++-
.../azure/key/vault/KeyVaultProducerTest.java | 310 +++++++++++
.../apache/camel/component/camunda/camunda.json | 4 +-
.../src/main/docs/camunda-component.adoc | 41 +-
.../camel/component/camunda/CamundaEndpoint.java | 14 +-
.../camunda/model/AbstractCamundaResponse.java | 4 -
.../component/camunda/model/DeploymentRequest.java | 2 -
.../camel/component/camunda/model/JobRequest.java | 8 +-
.../component/camunda/model/MessageRequest.java | 4 -
.../component/camunda/model/MessageResponse.java | 3 -
.../camunda/model/ProcessDeploymentResponse.java | 4 -
.../component/camunda/model/ProcessRequest.java | 5 -
.../component/camunda/model/ProcessResponse.java | 5 -
.../camunda/processor/AbstractBaseProcessor.java | 31 ++
.../camunda/processor/DeploymentProcessor.java | 1 +
.../component/camunda/processor/JobProcessor.java | 29 +-
.../camunda/processor/MessageProcessor.java | 19 +-
.../camunda/processor/ProcessProcessor.java | 31 +-
.../component/camunda/CamundaProducerTest.java | 301 ++++++++++
components/camel-chaos/pom.xml | 6 +
components/camel-chaos/src/main/docs/chaos.adoc | 35 +-
.../apache/camel/component/chaos/ChaosFaults.java | 58 +-
.../camel/component/chaos/ChaosPatterns.java | 27 +
.../camel/component/chaos/ChaosPollStrategy.java | 3 +-
.../apache/camel/component/chaos/ChaosRule.java | 9 +-
.../camel/component/chaos/ChaosRuleParser.java | 13 +-
.../camel/component/chaos/ChaosSendHook.java | 3 +-
.../camel/component/chaos/ChaosHttpFaultTest.java | 15 +-
.../component/chaos/ChaosNettyHttpFaultTest.java | 235 ++++++++
.../camel/component/chaos/ChaosRuleParserTest.java | 8 +-
.../camel/component/chaos/TestHttpComponent.java | 21 +-
.../component/google/bigquery/google-bigquery.json | 2 +-
.../google/bigquery/sql/google-bigquery-sql.json | 2 +-
.../src/main/docs/google-bigquery-component.adoc | 4 +
.../main/docs/google-bigquery-sql-component.adoc | 1 +
.../google/bigquery/GoogleBigQueryComponent.java | 4 +
.../google/bigquery/GoogleBigQueryEndpoint.java | 7 +-
.../google/bigquery/GoogleBigQueryProducer.java | 80 ++-
.../bigquery/sql/GoogleBigQuerySQLComponent.java | 4 +
.../bigquery/sql/GoogleBigQuerySQLEndpoint.java | 8 +-
.../bigquery/sql/GoogleBigQuerySQLProducer.java | 7 +-
...ogleBigQueryComponentConnectionFactoryTest.java | 110 ++++
.../unit/GoogleBigQueryProducerBodyTypeTest.java | 105 +++-
.../GoogleBigQuerySQLProducerStatementTest.java | 61 +++
.../camel/component/google/drive/google-drive.json | 9 +-
.../src/main/docs/google-drive-component.adoc | 69 +++
.../google/drive/GoogleDriveConfiguration.java | 2 +-
.../google/drive/GoogleDriveConsumer.java | 22 +-
.../google/drive/GoogleDriveEndpoint.java | 25 +-
.../google/drive/GoogleDriveProducer.java | 7 +-
.../google/drive/GoogleDriveRequestHelper.java | 54 ++
.../drive/internal/GoogleDriveConstants.java | 8 +-
.../component/google/drive/FileConverterIT.java | 13 +-
.../google/drive/GoogleDriveApiMethodsTest.java | 48 ++
.../google/drive/GoogleDriveMediaContentTest.java | 229 ++++++++
.../camel-google/camel-google-functions/pom.xml | 5 +
.../google/functions/google-functions.json | 4 +-
.../src/main/docs/google-functions-component.adoc | 12 +
.../functions/GoogleCloudFunctionsEndpoint.java | 23 +-
.../functions/GoogleCloudFunctionsProducer.java | 67 ++-
.../unit/GoogleCloudFunctionsCallFunctionTest.java | 275 ++++++++++
.../unit/GoogleCloudFunctionsComponentTest.java | 4 +-
components/camel-google/camel-google-mail/pom.xml | 3 +
.../GmailUsersMessagesEndpointConfiguration.java | 4 +-
.../mail/internal/GmailUsersMessagesApiMethod.java | 4 -
.../camel/component/google/mail/google-mail.json | 6 +-
.../google/mail/GoogleMailConfiguration.java | 2 +-
.../google/mail/GmailUsersMessagesIT.java | 3 -
.../google/mail/GoogleMailApiMethodsTest.java | 114 ++++
.../secret/manager/google-secret-manager.json | 4 +-
.../main/docs/google-secret-manager-component.adoc | 40 +-
.../manager/GoogleSecretManagerEndpoint.java | 20 +-
.../manager/GoogleSecretManagerProducer.java | 27 +-
.../unit/GoogleSecretManagerCreateSecretTest.java | 168 ++++++
.../camel-google/camel-google-sheets/pom.xml | 3 +
.../SheetsSpreadsheetsEndpointConfiguration.java | 2 +-
.../internal/SheetsSpreadsheetsApiMethod.java | 14 +-
.../component/google/sheets/google-sheets.json | 8 +-
.../src/main/docs/google-sheets-component.adoc | 9 +
.../google/sheets/GoogleSheetsConfiguration.java | 2 +-
.../google/sheets/GoogleSheetsEndpoint.java | 4 +-
.../google/sheets/GoogleSheetsApiMethodsTest.java | 114 ++++
.../GoogleSheetsConsumerSplitResultTest.java | 37 ++
.../google/texttospeech/google-text-to-speech.json | 6 +-
.../main/docs/google-text-to-speech-component.adoc | 32 +-
.../GoogleCloudTextToSpeechConfiguration.java | 13 +-
.../GoogleCloudTextToSpeechEndpoint.java | 16 +-
.../GoogleCloudTextToSpeechProducer.java | 48 +-
.../unit/GoogleCloudTextToSpeechProducerTest.java | 210 +++++++
.../component/google/vertexai/google-vertexai.json | 16 +-
.../src/main/docs/google-vertexai-component.adoc | 74 ++-
.../google/vertexai/GoogleVertexAIConstants.java | 33 +-
.../google/vertexai/GoogleVertexAIEndpoint.java | 34 +-
.../google/vertexai/GoogleVertexAIProducer.java | 210 +++++--
.../vertexai/GoogleVertexAIProducerBodyTest.java | 605 +++++++++++++++++++++
.../GoogleVertexAIProducerOptionsTest.java | 36 ++
.../camel/http/common/DefaultHttpBinding.java | 55 +-
.../org/apache/camel/http/common/HttpBinding.java | 3 +-
.../camel/http/common/HttpCommonEndpoint.java | 9 +-
.../org/apache/camel/http/common/HttpMessage.java | 4 +
.../http/common/DefaultHttpBindingGzipTest.java | 122 +++++
.../component/huaweicloud/dms/hwcloud-dms.json | 2 +-
.../src/main/docs/hwcloud-dms-component.adoc | 6 +-
.../component/huaweicloud/dms/DMSEndpoint.java | 16 +-
.../component/huaweicloud/dms/DMSProducer.java | 122 ++++-
.../huaweicloud/dms/CreateInstanceKafka1Test.java | 2 +-
.../huaweicloud/dms/CreateInstanceKafka2Test.java | 2 +-
.../dms/CreateInstanceMissingStorageSpaceTest.java | 2 +-
.../huaweicloud/dms/CreateInstanceRmq1Test.java | 2 +-
.../huaweicloud/dms/CreateInstanceRmq2Test.java | 2 +-
.../huaweicloud/dms/InstanceRequestBodyTest.java | 359 ++++++++++++
.../org/apache/camel/hwcloud-functiongraph.json | 4 +-
.../main/docs/hwcloud-functiongraph-component.adoc | 15 +
.../org/apache/camel/FunctionGraphEndpoint.java | 20 +-
.../org/apache/camel/FunctionGraphProducer.java | 72 ++-
.../java/org/apache/camel/FunctionGraphUtils.java | 38 +-
.../org/apache/camel/InvokeFunctionBodyTest.java | 234 ++++++++
.../camel-huawei/camel-huaweicloud-iam/pom.xml | 5 -
.../component/huaweicloud/iam/hwcloud-iam.json | 4 +-
.../src/main/docs/hwcloud-iam-component.adoc | 31 +-
.../component/huaweicloud/iam/IAMEndpoint.java | 18 +-
.../component/huaweicloud/iam/IAMProducer.java | 141 +++--
.../component/huaweicloud/iam/GetUserTest.java | 2 +-
.../huaweicloud/iam/IAMProducerJsonTest.java | 371 +++++++++++++
.../component/huaweicloud/iam/ListUsersTest.java | 2 +-
.../huaweicloud/iam/UpdateGroupJsonTest.java | 2 +-
.../component/huaweicloud/iam/UpdateGroupTest.java | 2 +-
.../component/huaweicloud/obs/OBSProducer.java | 11 +-
.../obs/PutObjectMandatoryNamesTest.java | 153 ++++++
.../component/huaweicloud/smn/hwcloud-smn.json | 4 +-
.../src/main/docs/hwcloud-smn-component.adoc | 13 +-
.../smn/SimpleNotificationEndpoint.java | 18 +-
.../smn/SimpleNotificationProducer.java | 70 ++-
.../huaweicloud/smn/constants/SmnProperties.java | 10 +
.../huaweicloud/smn/PublishMessageBodyTest.java | 260 +++++++++
.../smn/PublishTemplatedMessageFunctionalTest.java | 4 +-
.../smn/PublishTemplatedMessageTest.java | 4 +-
...tedMessageWithCustomEndpointFunctionalTest.java | 4 +-
...lishTemplatedMessageWithCustomEndpointTest.java | 4 +-
.../smn/PublishTextMessageFunctionalTest.java | 4 +-
.../huaweicloud/smn/PublishTextMessageTest.java | 6 +-
...extMessageWithCustomEndpointFunctionalTest.java | 4 +-
.../PublishTextMessageWithCustomEndpointTest.java | 6 +-
.../smn/constants/SmnPropertiesTest.java | 1 +
.../camel-ibm/camel-ibm-secrets-manager/pom.xml | 6 +
.../ibm/secrets/manager/ibm-secrets-manager.json | 4 +-
.../main/docs/ibm-secrets-manager-component.adoc | 70 ++-
.../secrets/manager/IBMSecretsManagerEndpoint.java | 27 +-
.../secrets/manager/IBMSecretsManagerProducer.java | 118 +++-
.../manager/IBMSecretsManagerProducerBodyTest.java | 504 +++++++++++++++++
.../camel-ibm/camel-ibm-watson-discovery/pom.xml | 6 +
.../WatsonDiscoveryProducerQueryTest.java | 148 +++++
.../camel-ibm/camel-ibm-watson-language/pom.xml | 6 +
.../camel-ibm-watson-speech-to-text/pom.xml | 6 +
.../docs/ibm-watson-speech-to-text-component.adoc | 7 +
.../ibm/watson/stt/WatsonSpeechToTextProducer.java | 40 +-
.../stt/WatsonSpeechToTextAudioStreamTest.java | 313 +++++++++++
.../camel-ibm-watson-text-to-speech/pom.xml | 6 +
.../component/ibm/watsonx/ai/ibm-watsonx-ai.json | 2 +-
.../src/main/docs/ibm-watsonx-ai-component.adoc | 13 +
.../ibm/watsonx/ai/WatsonxAiEndpoint.java | 21 +-
.../ai/handler/AbstractWatsonxAiHandler.java | 55 +-
.../ibm/watsonx/ai/WatsonxAiMessageBodyTest.java | 524 ++++++++++++++++++
.../camel-ibm/camel-ibm-watsonx-data/pom.xml | 6 +
.../ibm/watsonx/data/ibm-watsonx-data.json | 2 +-
.../src/main/docs/ibm-watsonx-data-component.adoc | 63 ++-
.../ibm/watsonx/data/WatsonxDataEndpoint.java | 9 +-
.../ibm/watsonx/data/WatsonxDataProducer.java | 50 +-
.../ibm/watsonx/data/WatsonxDataProducerTest.java | 255 +++++++++
components/camel-ibm/pom.xml | 16 +
.../org/apache/camel/component/jetty12/jetty.json | 2 +-
.../HttpChunkedNonStreamBodyAndFormStreamTest.java | 86 +++
.../component/jetty/HttpGzipNonStreamBodyTest.java | 66 +++
.../jetty/JettyMapHttpMessageBodyFalseTest.java | 52 ++
.../camel-jms/src/main/docs/jms-component.adoc | 8 +
.../org/apache/camel/component/jms/JmsBinding.java | 23 +-
.../camel/component/jms/JmsUnmappableBodyTest.java | 152 ++++++
.../src/main/docs/netty-http-component.adoc | 11 +
.../netty/http/HttpServerInitializerFactory.java | 9 +-
.../http/handlers/HttpServerChannelHandler.java | 31 +-
.../http/NettyHttpResponseCannotBeBuiltTest.java | 96 ++++
...NettyHttpSSLServerHostnameVerificationTest.java | 132 +++++
.../camel/component/netty/NettyPayloadHelper.java | 46 +-
.../handlers/ServerResponseFutureListener.java | 9 +
.../netty/NettyReplyWriteFailureTest.java | 79 +++
...TransferExchangeAllowSerializedHeadersTest.java | 135 +++++
.../apache/camel/component/servlet/servlet.json | 2 +-
...rvletChunkedNonStreamBodyAndFormStreamTest.java | 110 ++++
.../servlet/ServletGzipNonStreamBodyTest.java | 121 +++++
.../ServletMapHttpMessageBodyFalseTest.java | 65 +++
.../camel-sjms/src/main/docs/sjms-component.adoc | 3 +-
.../camel/component/sjms/jms/JmsBinding.java | 20 +-
.../consumer/InOutConsumerReplyFailureTest.java | 35 ++
.../sjms/producer/UnmappableBodyTest.java | 97 ++++
.../camel-sjms2/src/main/docs/sjms2-component.adoc | 3 +-
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../decorators/AbstractSpanDecorator.java | 21 +-
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 +++-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../decorators/AbstractHttpSpanDecorator.java | 41 +-
.../tracing/decorators/AbstractSpanDecorator.java | 21 +-
.../decorators/AbstractHttpSpanDecoratorTest.java | 95 +++-
.../decorators/AbstractSpanDecoratorTest.java | 56 ++
.../org/apache/camel/component/vertx/vertx.json | 4 +-
.../camel-vertx/src/main/docs/vertx-component.adoc | 3 +-
.../camel/component/vertx/VertxEndpoint.java | 10 +-
.../camel/component/vertx/VertxProducer.java | 35 +-
.../camel/component/vertx/VertxNullBodyTest.java | 140 +++++
.../vertx/VertxRequestReplyFailureTest.java | 13 -
.../org/apache/camel/support/PatternHelper.java | 26 +-
.../apache/camel/support/PatternHelperTest.java | 91 ++++
.../util/concurrent/BoundedExecutorService.java | 63 ++-
.../concurrent/BoundedExecutorServiceTest.java | 261 +++++++++
design/chaos.adoc | 6 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 351 ++++++++++++
.../modules/ROOT/pages/threading-model.adoc | 9 +
.../dsl/AzureFunctionsComponentBuilderFactory.java | 21 +
.../builder/endpoint/EndpointHeaderBuilders.java | 13 +
.../builder/endpoint/StaticEndpointBuilders.java | 34 +-
.../AtmosphereWebsocketEndpointBuilderFactory.java | 14 +-
.../dsl/FunctionsEndpointBuilderFactory.java | 36 ++
...gleCloudTextToSpeechEndpointBuilderFactory.java | 4 +-
.../dsl/GoogleDriveEndpointBuilderFactory.java | 51 +-
.../dsl/GoogleMailEndpointBuilderFactory.java | 12 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 10 +-
.../dsl/GoogleVertexAIEndpointBuilderFactory.java | 27 +-
.../dsl/JettyHttp12EndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/MNSEndpointBuilderFactory.java | 9 +-
.../endpoint/dsl/OSSEndpointBuilderFactory.java | 40 ++
.../dsl/ServletEndpointBuilderFactory.java | 14 +-
.../camel/dsl/jbang/it/CamelDebugITCase.java | 2 -
.../apache/camel/dsl/jbang/it/DevModeITCase.java | 4 +-
.../camel/dsl/jbang/it/InfrastructureITCase.java | 5 -
...ugITCase.java => InfrastructureListITCase.java} | 15 +-
.../apache/camel/dsl/jbang/it/JolokiaITCase.java | 2 -
.../apache/camel/dsl/jbang/it/OpenApiITCase.java | 12 +-
.../camel/dsl/jbang/it/RunCommandITCase.java | 18 +-
.../camel/dsl/jbang/it/RunCommandOnMqttITCase.java | 9 -
.../it/{CamelDebugITCase.java => StubITCase.java} | 17 +-
.../dsl/jbang/it/support/JBangTestSupport.java | 16 +-
dsl/camel-jbang/camel-launcher/pom.xml | 23 +
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 12 +-
parent/pom.xml | 16 +-
pom.xml | 2 +-
.../infra/cli/services/CliLocalProcessService.java | 15 +-
.../camel/test/infra/cli/services/CliService.java | 8 +
.../test/infra/cli/services/CliServiceFactory.java | 10 +
383 files changed, 15696 insertions(+), 1327 deletions(-)
create mode 100644
components/camel-alibaba/camel-alibaba-eventbridge/src/test/java/org/apache/camel/component/alibaba/eventbridge/PutEventsBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-fc/src/test/java/org/apache/camel/component/alibaba/fc/InvokeFunctionPayloadTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-kms/src/test/java/org/apache/camel/component/alibaba/kms/EncryptPlaintextTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSConsumerBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSProducerBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSProducerResponseHeadersTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-mns/src/test/java/org/apache/camel/component/alibaba/mns/MNSReceiveMessageOperationTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-oss/src/test/java/org/apache/camel/component/alibaba/oss/OSSConsumerIncludeBodyTest.java
create mode 100644
components/camel-alibaba/camel-alibaba-sls/src/test/java/org/apache/camel/component/alibaba/sls/PutLogsDocExampleTest.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/BedrockBodyHelper.java
create mode 100644
components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/CosmosDbProducerItemBodyTest.java
create mode 100644
components/camel-azure/camel-azure-eventgrid/src/test/java/org/apache/camel/component/azure/eventgrid/EventGridProducerTest.java
create mode 100644
components/camel-azure/camel-azure-functions/src/test/java/org/apache/camel/component/azure/functions/FunctionsProducerInvokeTest.java
create mode 100644
components/camel-azure/camel-azure-key-vault/src/test/java/org/apache/camel/component/azure/key/vault/KeyVaultProducerTest.java
create mode 100644
components/camel-camunda/src/test/java/org/apache/camel/component/camunda/CamundaProducerTest.java
create mode 100644
components/camel-chaos/src/test/java/org/apache/camel/component/chaos/ChaosNettyHttpFaultTest.java
create mode 100644
components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/unit/GoogleBigQueryComponentConnectionFactoryTest.java
create mode 100644
components/camel-google/camel-google-bigquery/src/test/java/org/apache/camel/component/google/bigquery/unit/sql/GoogleBigQuerySQLProducerStatementTest.java
create mode 100644
components/camel-google/camel-google-drive/src/main/java/org/apache/camel/component/google/drive/GoogleDriveRequestHelper.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-drive/src/test/java/org/apache/camel/component/google/drive/GoogleDriveMediaContentTest.java
create mode 100644
components/camel-google/camel-google-functions/src/test/java/org/apache/camel/component/google/functions/unit/GoogleCloudFunctionsCallFunctionTest.java
create mode 100644
components/camel-google/camel-google-mail/src/test/java/org/apache/camel/component/google/mail/GoogleMailApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-secret-manager/src/test/java/org/apache/camel/component/google/secret/manager/unit/GoogleSecretManagerCreateSecretTest.java
create mode 100644
components/camel-google/camel-google-sheets/src/test/java/org/apache/camel/component/google/sheets/GoogleSheetsApiMethodsTest.java
create mode 100644
components/camel-google/camel-google-text-to-speech/src/test/java/org/apache/camel/component/google/texttospeech/unit/GoogleCloudTextToSpeechProducerTest.java
create mode 100644
components/camel-google/camel-google-vertexai/src/test/java/org/apache/camel/component/google/vertexai/GoogleVertexAIProducerBodyTest.java
create mode 100644
components/camel-http-common/src/test/java/org/apache/camel/http/common/DefaultHttpBindingGzipTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-dms/src/test/java/org/apache/camel/component/huaweicloud/dms/InstanceRequestBodyTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-functiongraph/src/test/java/org/apache/camel/InvokeFunctionBodyTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-iam/src/test/java/org/apache/camel/component/huaweicloud/iam/IAMProducerJsonTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-obs/src/test/java/org/apache/camel/component/huaweicloud/obs/PutObjectMandatoryNamesTest.java
create mode 100644
components/camel-huawei/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishMessageBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-secrets-manager/src/test/java/org/apache/camel/component/ibm/secrets/manager/IBMSecretsManagerProducerBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-watson-discovery/src/test/java/org/apache/camel/component/ibm/watson/discovery/WatsonDiscoveryProducerQueryTest.java
create mode 100644
components/camel-ibm/camel-ibm-watson-speech-to-text/src/test/java/org/apache/camel/component/ibm/watson/stt/WatsonSpeechToTextAudioStreamTest.java
create mode 100644
components/camel-ibm/camel-ibm-watsonx-ai/src/test/java/org/apache/camel/component/ibm/watsonx/ai/WatsonxAiMessageBodyTest.java
create mode 100644
components/camel-ibm/camel-ibm-watsonx-data/src/test/java/org/apache/camel/component/ibm/watsonx/data/WatsonxDataProducerTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpChunkedNonStreamBodyAndFormStreamTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpGzipNonStreamBodyTest.java
create mode 100644
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyMapHttpMessageBodyFalseTest.java
create mode 100644
components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsUnmappableBodyTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpResponseCannotBeBuiltTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpSSLServerHostnameVerificationTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyReplyWriteFailureTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTransferExchangeAllowSerializedHeadersTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletChunkedNonStreamBodyAndFormStreamTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletGzipNonStreamBodyTest.java
create mode 100644
components/camel-servlet/src/test/java/org/apache/camel/component/servlet/ServletMapHttpMessageBodyFalseTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/UnmappableBodyTest.java
create mode 100644
components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxNullBodyTest.java
copy
dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/{CamelDebugITCase.java
=> InfrastructureListITCase.java} (65%)
copy
dsl/camel-jbang/camel-jbang-it/src/test/java/org/apache/camel/dsl/jbang/it/{CamelDebugITCase.java
=> StubITCase.java} (65%)
