This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-26159-salesforce-map-body
in repository https://gitbox.apache.org/repos/asf/camel.git
from a7ecb7845832 CAMEL-26159: camel-salesforce - fail the composite
operations on an unparseable response
add f97346b80f2c chore(deps): Bump org.duckdb:duckdb_jdbc from 1.5.6.0 to
2.0.0.0 (#28881)
add 030d45983834 CAMEL-26161: camel-zendesk - the documented syntax
zendesk:methodName fails endpoint creation (#28936)
add af6bef4113d8 CAMEL-26493: camel-jbang - AI tools: a Citrus test is
checked as YAML, not as a route, and the examples show their Citrus tests
(#28872)
add c21135a79196 CAMEL-26495: camel-jbang - camel run and camel_run do not
start a Citrus test, and say to use camel test run (#28884)
add 9af87a8bedb9 CAMEL-25973: camel-language - binary=true with a file: or
classpath: script returns the content as a stream (#28889)
add 3af4458ddef7 CAMEL-26062: camel-smooks - SAXSource, remote file, File
and Path bodies are read, exports come in a fixed order (#28890)
add 42b0c1c1e151 CAMEL-26100: camel-aws2-athena - result headers are not
taken as the input of a later operation (#28891)
add d56ad66487bc CAMEL-26069: camel-aws-bedrock - send the body as bytes,
and fail the streaming of image and embedding models (#28892)
add ac961f81d7cb CAMEL-26117: camel-debezium - the row flattened by
ExtractNewRecordState is the body, and mongodb updates expose their
updateDescription (#28893)
add 1452a4594383 CAMEL-26071: camel-aws-bedrock -
aws-bedrock-agent-runtime: invokeFlow converts the body, and the operation
header works on an endpoint of another operation (#28894)
add 0e2a286dc6de CAMEL-26118: camel-flowable - a producer created before
its channel is deployed sends once the channel is deployed, and fails with a
clear error until then (#28895)
add 3eb4c51cb6eb CAMEL-26120: camel-bonita - startCase sets the id of the
started case in a header, and a body that is not a Map fails with
InvalidPayloadException (#28897)
add 3464d84544f2 CAMEL-26121: camel-flink - use the component dataStream
options, and return a DataStream with the default collect (#28898)
add e6d529b9d3e3 CAMEL-26122: camel-spring-batch - skip null headers and
honour jobFromHeader=false (#28899)
add 0ec3f6909c26 CAMEL-26124: camel-jt400 - Fix program call without
outputFieldsIdx and with a List body (#28900)
add 8b900e03ccdf CAMEL-26125: camel-jcr - the insert operation keeps the
headers of the message (#28901)
add 1635587b1f90 CAMEL-26123: camel-optaplanner - one SolverManager per
endpoint, per-context consumers and sync events (#28902)
add 22806dff2f7b CAMEL-26127: camel-fop - accept a DOM or Source body and
fail clearly on no body (#28903)
add 41d9dd8ab401 CAMEL-26128: camel-flatpack - with splitRows each row
message has its own row, and a failing row fails the producer (#28906)
add ca69f7cf4424 CAMEL-26133: camel-robotframework - skip null body,
header, variable and property values (#28907)
add c0177a5a77a0 CAMEL-26132: camel-rss - Fail the exchange when the feed
cannot be cloned for a split entry (#28908)
add 6eec69b21a39 CAMEL-26134: camel-test-citrus - Validate byte[], file
and stream bodies by their content (#28909)
add 62c8f6e00fca CAMEL-26140: camel-undertow - send a number as text, fail
on a Map or object body, read a DELETE body, null body for a 204 (#28910)
add 958036619c28 CAMEL-26139: camel-servlet - attachmentMultipartBinding
only reads parts of multipart/form-data requests (#28912)
add 9aba86e0ad37 CAMEL-26141: camel-atmosphere-websocket - fix query
parameter without a value and the useStreaming description (#28913)
add c3ce839be05f CAMEL-26136: camel-netty - convert replies for the
default codec, fail on useByteBuf, ignore replies with sync=false (#28914)
add 1ec55622dbb4 CAMEL-26142: camel-spring-ws - null reply body, non-XML
reply body, and File/InputStream producer bodies (#28915)
add 7a48feff33a3 CAMEL-26145: camel-mybatis - Keep the body with InOut,
and fail an Insert, Update or Delete without a body when the statement has
parameters (#28916)
add 137d447a68b1 CAMEL-26146: camel-jooq - fail on an empty body and drop
the CONSUME operation from the catalog (#28917)
add f345ef6a17a6 CAMEL-26148: camel-sql - sql and sql-stored batch update
count and single Map body (#28918)
add c09c01f957f9 CAMEL-26149: camel-duckdb - document the query option
precedence, hint at the operation on a wrong statement kind, and accept a Path
or bytes body for copy (#28919)
add cf6980d06db0 CAMEL-26143: camel-cxf - fix byte[] reply, POJO parameter
splitting and bodies sent as empty messages (#28920)
add e6433f423187 CAMEL-26151: camel-pg-replication-slot - keep the
generated exchange id and put the LSN in a header (#28921)
add a1b1c8b719b0 CAMEL-26150: camel-clickhouse - return binary query
results as byte[] and fail List inserts with a clear message (#28922)
add fe77c8e2bc3e CAMEL-26144: camel-cxfrs - reply with an unchanged
request body and send a whole List body (#28923)
add f5475dfc57c9 CAMEL-26153: camel-hivemq - fail the exchange for a body
that does not convert to byte[] instead of publishing an empty payload (#28924)
add 3f3f25513695 CAMEL-26154: camel-iggy - send binary bodies as bytes and
give the consumer body as bytes (#28927)
add 9ef0c09fffde CAMEL-26155: camel-rocketmq - waitForSendResult=false
completes the exchange synchronously, and the headers are named CamelRocketMQ
(#28933)
add 48894fe86592 CAMEL-26160: camel-servicenow - remove dead Map branch in
AbstractServiceNowProcessor.unwrap (#28935)
add 2a57a18cad45 CAMEL-26163: camel-wordpress - convert a JSON text or Map
body to a Post or User (#28939)
add 9ee1e7cfade6 CAMEL-26164: camel-whatsapp - fix webhook query parsing
and a missing HTTP method (#28940)
add 020181ed8a63 CAMEL-26158: camel-vertx - reply with a stream as a
Buffer, and with a failure when the reply has no codec (#28941)
add 9a9c07ebd051 CAMEL-26166: camel-stripe - convert bytes and stream
bodies, read the CamelStripeOperation header, no retrieve before update (#28944)
add 4afa8ead45a3 CAMEL-26168: camel-twitter - fail a direct message with
no body, list only usable timeline types (#28946)
add b0ac6c542251 Merge remote-tracking branch 'origin/main' into
CAMEL-26159-salesforce-map-body
No new revisions were added by this update.
Summary of changes:
.../catalog/components/atmosphere-websocket.json | 2 +-
.../components/aws-bedrock-agent-runtime.json | 12 +-
.../camel/catalog/components/aws-bedrock.json | 12 +-
.../apache/camel/catalog/components/bonita.json | 7 +-
.../apache/camel/catalog/components/citrus.json | 2 +-
.../camel/catalog/components/clickhouse.json | 4 +-
.../org/apache/camel/catalog/components/cxf.json | 4 +-
.../org/apache/camel/catalog/components/cxfrs.json | 4 +-
.../camel/catalog/components/debezium-mongodb.json | 5 +-
.../apache/camel/catalog/components/duckdb.json | 6 +-
.../apache/camel/catalog/components/flatpack.json | 4 +-
.../org/apache/camel/catalog/components/flink.json | 4 +-
.../org/apache/camel/catalog/components/fop.json | 2 +-
.../apache/camel/catalog/components/hivemq.json | 2 +-
.../org/apache/camel/catalog/components/iggy.json | 15 +-
.../org/apache/camel/catalog/components/jooq.json | 4 +-
.../org/apache/camel/catalog/components/jt400.json | 2 +-
.../camel/catalog/components/optaplanner.json | 4 +-
.../catalog/components/pg-replication-slot.json | 5 +-
.../camel/catalog/components/robotframework.json | 2 +-
.../apache/camel/catalog/components/rocketmq.json | 44 +--
.../camel/catalog/components/spring-batch.json | 4 +-
.../camel/catalog/components/sql-stored.json | 6 +-
.../org/apache/camel/catalog/components/sql.json | 4 +-
.../apache/camel/catalog/components/stripe.json | 4 +-
.../catalog/components/twitter-directmessage.json | 2 +-
.../camel/catalog/components/twitter-timeline.json | 2 +-
.../org/apache/camel/catalog/components/vertx.json | 6 +-
.../apache/camel/catalog/components/wordpress.json | 2 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 12 +-
.../camel/catalog/docs/aws-bedrock-component.adoc | 24 +-
.../camel/catalog/docs/aws2-athena-component.adoc | 15 +-
.../camel/catalog/docs/bonita-component.adoc | 5 +
.../camel/catalog/docs/citrus-component.adoc | 10 +
.../camel/catalog/docs/clickhouse-component.adoc | 13 +-
.../apache/camel/catalog/docs/cxf-component.adoc | 7 +
.../apache/camel/catalog/docs/cxfrs-component.adoc | 11 +-
.../camel/catalog/docs/debezium-db2-component.adoc | 6 +
.../catalog/docs/debezium-mongodb-component.adoc | 10 +
.../catalog/docs/debezium-mysql-component.adoc | 6 +
.../catalog/docs/debezium-oracle-component.adoc | 6 +
.../catalog/docs/debezium-postgres-component.adoc | 6 +
.../catalog/docs/debezium-sqlserver-component.adoc | 6 +
.../camel/catalog/docs/duckdb-component.adoc | 10 +-
.../camel/catalog/docs/flatpack-component.adoc | 12 +-
.../apache/camel/catalog/docs/flink-component.adoc | 3 +-
.../camel/catalog/docs/flowable-component.adoc | 8 +-
.../camel/catalog/docs/hivemq-component.adoc | 4 +
.../apache/camel/catalog/docs/iggy-component.adoc | 24 +-
.../apache/camel/catalog/docs/jooq-component.adoc | 3 +
.../apache/camel/catalog/docs/jt400-component.adoc | 8 +-
.../camel/catalog/docs/language-component.adoc | 44 +++
.../camel/catalog/docs/mybatis-component.adoc | 6 +
.../apache/camel/catalog/docs/netty-component.adoc | 10 +
.../camel/catalog/docs/optaplanner-component.adoc | 12 +-
.../docs/pg-replication-slot-component.adoc | 3 +
.../catalog/docs/robotframework-component.adoc | 24 +-
.../camel/catalog/docs/rocketmq-component.adoc | 20 +-
.../apache/camel/catalog/docs/rss-component.adoc | 5 +
.../camel/catalog/docs/smooks-component.adoc | 4 +-
.../camel/catalog/docs/spring-batch-component.adoc | 8 +-
.../camel/catalog/docs/spring-ws-component.adoc | 8 +
.../apache/camel/catalog/docs/sql-component.adoc | 4 +
.../camel/catalog/docs/sql-stored-component.adoc | 18 +
.../camel/catalog/docs/stripe-component.adoc | 9 +-
.../docs/twitter-directmessage-component.adoc | 3 +-
.../camel/catalog/docs/undertow-component.adoc | 11 +
.../apache/camel/catalog/docs/vertx-component.adoc | 18 +-
.../camel/catalog/docs/wordpress-component.adoc | 5 +
.../camel/catalog/main/important-headers.json | 2 +-
.../atmosphere/websocket/atmosphere-websocket.json | 2 +-
.../atmosphere/websocket/WebsocketConsumer.java | 10 +-
.../atmosphere/websocket/WebsocketEndpoint.java | 3 +-
.../websocket/WebsocketQueryParameterTest.java | 63 ++++
.../agentruntime/aws-bedrock-agent-runtime.json | 12 +-
.../aws2/bedrock/runtime/aws-bedrock.json | 12 +-
.../docs/aws-bedrock-agent-runtime-component.adoc | 12 +-
.../src/main/docs/aws-bedrock-component.adoc | 24 +-
.../BedrockAgentRuntimeConfiguration.java | 6 +-
.../agentruntime/BedrockAgentRuntimeConstants.java | 2 +-
.../agentruntime/BedrockAgentRuntimeEndpoint.java | 37 +-
.../agentruntime/BedrockAgentRuntimeProducer.java | 51 +--
.../aws2/bedrock/runtime/BedrockConstants.java | 9 +-
.../aws2/bedrock/runtime/BedrockEndpoint.java | 10 +-
.../aws2/bedrock/runtime/BedrockProducer.java | 148 ++++++--
.../bedrock/runtime/stream/Ai21StreamParser.java | 86 +++++
.../runtime/stream/ConverseStreamHandler.java | 16 +-
.../bedrock/runtime/stream/NovaStreamParser.java | 74 ++++
.../runtime/stream/StreamParserFactory.java | 8 +-
.../BedrockAgentRuntimeEndpointTest.java | 38 ++
.../BedrockAgentRuntimeProducerInvokeFlowTest.java | 35 ++
.../BedrockAgentRuntimeProducerOperationTest.java | 146 ++++++++
...BedrockInvokeTextModelUnsupportedModelTest.java | 1 +
.../runtime/BedrockProducerRequestTest.java | 417 +++++++++++++++++++++
.../runtime/stream/ConverseStreamHandlerTest.java | 43 +++
.../src/main/docs/aws2-athena-component.adoc | 15 +-
.../component/aws2/athena/Athena2Producer.java | 97 +++--
.../athena/Athena2ProducerResultHeadersTest.java | 253 +++++++++++++
.../org/apache/camel/component/bonita/bonita.json | 7 +-
.../src/main/docs/bonita-component.adoc | 5 +
.../camel/component/bonita/BonitaConstants.java} | 16 +-
.../camel/component/bonita/BonitaEndpoint.java | 7 +-
.../bonita/producer/BonitaStartProducer.java | 9 +-
.../component/bonita/BonitaStartProducerTest.java | 131 +++++++
.../camel/component/clickhouse/clickhouse.json | 4 +-
.../src/main/docs/clickhouse-component.adoc | 13 +-
.../component/clickhouse/ClickHouseConstants.java | 4 +-
.../component/clickhouse/ClickHouseEndpoint.java | 13 +-
.../component/clickhouse/ClickHouseProducer.java | 55 ++-
.../clickhouse/ClickHouseProducerTest.java | 85 ++++-
.../integration/ClickHouseProducerIT.java | 42 +++
.../apache/camel/component/cxf/jaxrs/cxfrs.json | 4 +-
.../src/main/docs/cxfrs-component.adoc | 11 +-
.../camel/component/cxf/jaxrs/CxfRsEndpoint.java | 12 +-
.../component/cxf/jaxrs/DefaultCxfRsBinding.java | 40 +-
.../component/cxf/jaxrs/SimpleCxfRsBinding.java | 3 +-
.../cxf/jaxrs/CxfRsConsumerUnchangedBodyTest.java | 99 +++++
.../cxf/jaxrs/DefaultCxfRsBindingTest.java | 89 +++++
.../org/apache/camel/component/cxf/jaxws/cxf.json | 4 +-
.../src/main/docs/cxf-component.adoc | 7 +
.../camel/component/cxf/jaxws/CxfEndpoint.java | 37 +-
.../camel/component/cxf/jaxws/CxfProducer.java | 25 +-
.../component/cxf/jaxws/DefaultCxfBinding.java | 43 ++-
.../component/cxf/jaxws/BodyTypeService.java} | 17 +-
.../component/cxf/jaxws/CxfBodyTypesTest.java | 174 +++++++++
.../component/debezium/DebeziumConstants.java | 5 +
.../camel/component/debezium/DebeziumEndpoint.java | 38 +-
.../component/debezium/DebeziumTypeConverter.java | 34 +-
.../component/debezium/DebeziumEndpointTest.java | 95 ++++-
.../debezium/DebeziumTypeConverterTest.java | 27 ++
.../src/main/docs/debezium-db2-component.adoc | 6 +
.../debezium/mongodb/debezium-mongodb.json | 5 +-
.../src/main/docs/debezium-mongodb-component.adoc | 10 +
.../debezium/mongodb/DebeziumMongodbEndpoint.java | 28 +-
.../mongodb/DebeziumMongodbEndpointTest.java | 125 ++++++
.../src/main/docs/debezium-mysql-component.adoc | 6 +
.../src/main/docs/debezium-oracle-component.adoc | 6 +
.../src/main/docs/debezium-postgres-component.adoc | 6 +
.../main/docs/debezium-sqlserver-component.adoc | 6 +
.../org/apache/camel/component/duckdb/duckdb.json | 6 +-
.../src/main/docs/duckdb-component.adoc | 10 +-
.../camel/component/duckdb/DuckDbConstants.java | 4 +-
.../camel/component/duckdb/DuckDbEndpoint.java | 8 +-
.../camel/component/duckdb/DuckDbProducer.java | 31 +-
.../camel/component/duckdb/DuckDbProducerTest.java | 98 +++++
.../apache/camel/component/flatpack/flatpack.json | 4 +-
.../src/main/docs/flatpack-component.adoc | 12 +-
.../camel/component/flatpack/DataSetRow.java | 343 +++++++++++++++++
.../component/flatpack/FlatpackConverter.java | 4 +
.../camel/component/flatpack/FlatpackEndpoint.java | 32 +-
.../camel/component/flatpack/FlatpackProducer.java | 6 +-
.../component/flatpack/FlatpackSplitRowsTest.java | 201 ++++++++++
.../org/apache/camel/component/flink/flink.json | 4 +-
.../camel-flink/src/main/docs/flink-component.adoc | 3 +-
.../component/flink/DataStreamFlinkProducer.java | 6 +-
.../camel/component/flink/FlinkEndpoint.java | 27 +-
.../DataStreamComponentOptionsAndCollectTest.java | 87 +++++
.../src/main/docs/flowable-component.adoc | 8 +-
.../camel/component/flowable/FlowableEndpoint.java | 8 +
.../camel/component/flowable/FlowableProducer.java | 26 +-
.../FlowableProducerChannelNotDeployedTest.java | 85 +++++
.../resources/channel/userRouteChannel.channel | 10 +
.../org/apache/camel/component/fop/fop.json | 2 +-
.../apache/camel/component/fop/FopEndpoint.java | 7 +-
.../apache/camel/component/fop/FopProducer.java | 18 +-
.../apache/camel/component/fop/FopBodyTest.java | 93 +++++
.../org/apache/camel/component/hivemq/hivemq.json | 2 +-
.../src/main/docs/hivemq-component.adoc | 4 +
.../camel/component/hivemq/HiveMQEndpoint.java | 3 +-
.../camel/component/hivemq/HiveMQProducer.java | 27 +-
.../component/hivemq/HiveMQProducerBodyTest.java | 187 +++++++++
.../org/apache/camel/component/iggy/iggy.json | 15 +-
.../camel-iggy/src/main/docs/iggy-component.adoc | 24 +-
.../apache/camel/component/iggy/IggyConstants.java | 18 +
.../apache/camel/component/iggy/IggyEndpoint.java | 16 +-
.../camel/component/iggy/IggyFetchRecords.java | 3 +-
.../apache/camel/component/iggy/IggyProducer.java | 45 ++-
.../camel/component/iggy/IggyConsumerIT.java | 2 +-
.../camel/component/iggy/IggyMessageBodyTest.java | 244 ++++++++++++
.../apache/camel/component/iggy/IggyTestBase.java | 5 +-
.../apache/camel/component/jcr/JcrProducer.java | 2 +-
.../camel/component/jcr/JcrProducerTest.java | 24 ++
.../org/apache/camel/component/jooq/jooq.json | 4 +-
.../camel-jooq/src/main/docs/jooq-component.adoc | 3 +
.../camel/component/jooq/JooqConfiguration.java | 2 +-
.../apache/camel/component/jooq/JooqEndpoint.java | 9 +-
.../camel/component/jooq/JooqComponentTest.java | 12 +
.../component/jooq/JooqProducerEmptyBodyTest.java | 93 +++++
.../org/apache/camel/component/jt400/jt400.json | 2 +-
.../camel-jt400/src/main/docs/jt400-component.adoc | 8 +-
.../camel/component/jt400/Jt400Endpoint.java | 23 +-
.../camel/component/jt400/Jt400PgmProducer.java | 31 +-
.../component/jt400/Jt400PgmProducerTest.java | 130 +++++++
.../src/main/docs/language-component.adoc | 44 +++
.../camel/component/language/LanguageEndpoint.java | 5 +-
.../camel/component/language/LanguageProducer.java | 18 +-
.../src/main/docs/mybatis-component.adoc | 6 +
.../camel/component/mybatis/MyBatisProducer.java | 23 +-
.../mybatis/MyBatisInOutKeepsBodyTest.java | 127 +++++++
.../mybatis/MyBatisInsertWithRollbackTest.java | 8 +-
.../component/mybatis/MyBatisNullBodyTest.java | 102 +++++
.../org/apache/camel/component/mybatis/Account.xml | 15 +
.../camel-netty/src/main/docs/netty-component.adoc | 10 +
.../camel/component/netty/NettyConfiguration.java | 10 +
.../camel/component/netty/NettyPayloadHelper.java | 25 +-
.../netty/handlers/ClientChannelHandler.java | 9 +
.../netty/handlers/ServerChannelHandler.java | 44 ++-
.../netty/NettyDefaultCodecReplyTest.java | 91 +++++
.../netty/NettyProducerSyncFalseReplyTest.java | 64 ++++
.../camel/component/netty/NettyUseByteBufTest.java | 86 +++++
.../camel/component/optaplanner/optaplanner.json | 4 +-
.../src/main/docs/optaplanner-component.adoc | 12 +-
.../optaplanner/OptaPlannerComponent.java | 29 ++
.../optaplanner/OptaPlannerConfiguration.java | 3 +-
.../component/optaplanner/OptaPlannerEndpoint.java | 75 +++-
.../component/optaplanner/OptaPlannerProducer.java | 14 +-
.../OptaPlannerConfigFileSolverManagerTest.java | 79 ++++
.../OptaPlannerConsumerCamelContextTest.java | 88 +++++
.../optaplanner/OptaPlannerSyncConsumerTest.java | 63 ++++
.../component/optaplanner/solverConfigQuick.xml | 38 ++
.../pg/replication/slot/pg-replication-slot.json | 5 +-
.../main/docs/pg-replication-slot-component.adoc | 3 +
.../slot/PgReplicationSlotConstants.java} | 19 +-
.../slot/PgReplicationSlotConsumer.java | 2 +-
.../slot/PgReplicationSlotEndpoint.java | 6 +-
.../PgReplicationSlotConsumerReconnectTest.java | 21 +-
.../slot/PgReplicationSlotConsumerTest.java | 68 ++++
.../component/robotframework/robotframework.json | 2 +-
.../src/main/docs/robotframework-component.adoc | 24 +-
.../robotframework/RobotFrameworkCamelUtils.java | 48 ++-
.../robotframework/RobotFrameworkEndpoint.java | 2 +-
.../RobotFrameworkCamelUtilsTest.java | 46 +++
.../RobotFrameworkComponentTest.java | 24 ++
.../robotframework/RobotFrameworkConsumerTest.java | 52 +++
.../set_variable_camel_no_body.robot | 27 ++
components/camel-rocketmq/pom.xml | 4 +-
.../apache/camel/component/rocketmq/rocketmq.json | 44 +--
.../src/main/docs/rocketmq-component.adoc | 20 +-
.../component/rocketmq/RocketMQComponent.java | 8 +-
.../component/rocketmq/RocketMQConstants.java | 40 +-
.../camel/component/rocketmq/RocketMQEndpoint.java | 8 +-
.../camel/component/rocketmq/RocketMQProducer.java | 30 +-
.../rocketmq/RocketMQProducerSendFailureTest.java | 44 ++-
.../camel-rss/src/main/docs/rss-component.adoc | 5 +
.../apache/camel/component/rss/RssEndpoint.java | 12 +-
.../component/rss/RssEntryCloneFailureTest.java | 136 +++++++
.../servicenow/AbstractServiceNowProcessor.java | 11 +-
.../component/servicenow/ServiceNowUnwrapTest.java | 117 ++++++
.../component/servlet/AttachmentHttpBinding.java | 11 +
.../component/servlet/MultipartUploadTest.java | 21 ++
.../src/main/docs/smooks-component.adoc | 4 +-
.../camel/component/smooks/SmooksProcessor.java | 69 +++-
.../camel/component/smooks/routing/BeanRouter.java | 7 +-
.../component/smooks/SmooksReaderBodyTest.java | 177 +++++++++
.../component/smooks/routing/BeanRouterTest.java | 32 ++
.../camel/component/spring/batch/spring-batch.json | 4 +-
.../src/main/docs/spring-batch-component.adoc | 8 +-
.../spring/batch/SpringBatchConstants.java | 3 +-
.../spring/batch/SpringBatchEndpoint.java | 2 +-
.../spring/batch/SpringBatchProducer.java | 15 +-
.../spring/batch/SpringBatchEndpointTest.java | 31 ++
.../src/main/docs/spring-ws-component.adoc | 8 +
.../spring/ws/SpringWebserviceConsumer.java | 4 +-
.../spring/ws/SpringWebserviceHelper.java | 27 ++
.../spring/ws/SpringWebserviceMessage.java | 24 +-
.../spring/ws/SpringWebserviceProducer.java | 3 +-
.../component/spring/ws/ConsumerReplyBodyTest.java | 137 +++++++
.../spring/ws/ProducerLocalRouteTest.java | 45 +++
.../spring/ws/ConsumerReplyBodyTest-context.xml | 29 ++
.../spring/ws/ProducerLocalRouteTest-context.xml | 13 +-
.../org/apache/camel/component/sql/sql.json | 4 +-
.../camel/component/sql/stored/sql-stored.json | 6 +-
.../camel-sql/src/main/docs/sql-component.adoc | 4 +
.../src/main/docs/sql-stored-component.adoc | 18 +
.../apache/camel/component/sql/SqlConstants.java | 5 +-
.../apache/camel/component/sql/SqlEndpoint.java | 4 +-
.../apache/camel/component/sql/SqlProducer.java | 20 +-
.../component/sql/stored/SqlStoredConstants.java | 6 +-
.../component/sql/stored/SqlStoredEndpoint.java | 8 +-
.../component/sql/stored/SqlStoredProducer.java | 21 +-
.../camel/component/sql/SqlProducerBatchTest.java | 198 ++++++++++
.../component/sql/stored/ProducerBatchTest.java | 44 +++
.../org/apache/camel/component/stripe/stripe.json | 4 +-
.../src/main/docs/stripe-component.adoc | 9 +-
.../camel/component/stripe/StripeConstants.java | 4 +-
.../camel/component/stripe/StripeEndpoint.java | 6 +-
.../camel/component/stripe/StripeProducer.java | 116 +++---
.../stripe/StripeProducerRequestTest.java | 198 ++++++++++
.../org/apache/camel/component/citrus/citrus.json | 2 +-
.../src/main/docs/citrus-component.adoc | 10 +
.../camel/component/citrus/CitrusEndpoint.java | 11 +-
.../citrus/CitrusValidationProcessor.java | 38 +-
.../citrus/CitrusValidateBodyTypesTest.java | 181 +++++++++
.../directmessage/twitter-directmessage.json | 2 +-
.../twitter/timeline/twitter-timeline.json | 2 +-
.../main/docs/twitter-directmessage-component.adoc | 3 +-
.../directmessage/DirectMessageProducer.java | 4 +-
.../TwitterDirectMessageEndpoint.java | 2 +-
.../twitter/timeline/TwitterTimelineEndpoint.java | 2 +-
.../component/twitter/util/TwitterConverter.java | 3 +
.../twitter/DirectMessageProducerTest.java | 77 ++++
.../component/twitter/TwitterConverterTest.java | 55 +++
.../twitter/TwitterTimelineEndpointTest.java | 41 ++
.../src/main/docs/undertow-component.adoc | 11 +
.../undertow/DefaultUndertowHttpBinding.java | 30 +-
.../camel/component/undertow/UndertowConsumer.java | 23 +-
.../camel/component/undertow/UndertowHelper.java | 45 +++
.../camel/component/undertow/UndertowProducer.java | 30 +-
.../undertow/UndertowBodyConversionTest.java | 218 +++++++++++
.../undertow/UndertowSwitchingStatus204Test.java | 6 +-
.../org/apache/camel/component/vertx/vertx.json | 6 +-
.../camel-vertx/src/main/docs/vertx-component.adoc | 18 +-
.../camel/component/vertx/VertxBodyHelper.java | 47 +++
.../camel/component/vertx/VertxConsumer.java | 12 +-
.../camel/component/vertx/VertxEndpoint.java | 16 +-
.../camel/component/vertx/VertxProducer.java | 7 +-
.../vertx/VertxRequestReplyFailureTest.java | 31 +-
.../vertx/VertxRequestReplyStreamTest.java | 90 +++++
.../whatsapp/WhatsAppWebhookProcessor.java | 44 ++-
.../whatsapp/WhatsAppWebhookProcessorTest.java | 163 ++++++++
.../component/whatsapp/WhatsAppWebhookTest.java | 16 +
.../camel/component/wordpress/wordpress.json | 2 +-
.../src/main/docs/wordpress-component.adoc | 5 +
.../component/wordpress/WordpressEndpoint.java | 6 +-
.../producer/AbstractWordpressProducer.java | 37 +-
.../wordpress/producer/WordpressPostProducer.java | 8 +-
.../wordpress/producer/WordpressUserProducer.java | 10 +-
.../wordpress/WordpressPostOperationTest.java | 63 ++++
.../wordpress/WordpressUserOperationTest.java | 46 +++
.../test/WordpressServerHttpRequestHandler.java | 20 +
.../camel/component/zendesk/ZendeskComponent.java | 4 +
.../component/zendesk/ZendeskApiNameTest.java | 101 +++++
.../ConstantLanguageBinaryResourceTest.java | 40 ++
.../apache/camel/util/ImportantHeaderUtils.java | 2 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 325 ++++++++++++++++
.../modules/ROOT/pages/camel-jbang-mcp.adoc | 7 +-
.../modules/ROOT/pages/camel-jbang-running.adoc | 6 +
.../modules/ROOT/pages/camel-jbang-test.adoc | 18 +-
...BedrockAgentRuntimeComponentBuilderFactory.java | 6 +-
.../dsl/RocketmqComponentBuilderFactory.java | 8 +-
.../builder/endpoint/EndpointHeaderBuilders.java | 40 ++
.../builder/endpoint/StaticEndpointBuilders.java | 6 +-
.../AtmosphereWebsocketEndpointBuilderFactory.java | 30 +-
.../BedrockAgentRuntimeEndpointBuilderFactory.java | 11 +-
.../dsl/BedrockEndpointBuilderFactory.java | 11 +-
.../endpoint/dsl/BonitaEndpointBuilderFactory.java | 36 ++
.../dsl/ClickHouseEndpointBuilderFactory.java | 4 +-
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 15 +
.../endpoint/dsl/DuckDbEndpointBuilderFactory.java | 7 +-
.../endpoint/dsl/FlinkEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/IggyEndpointBuilderFactory.java | 134 +++++++
.../dsl/OptaPlannerEndpointBuilderFactory.java | 9 +-
.../PgReplicationSlotEndpointBuilderFactory.java | 39 ++
.../dsl/RocketMQEndpointBuilderFactory.java | 136 +++----
.../dsl/SpringBatchEndpointBuilderFactory.java | 3 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java | 5 +-
.../dsl/SqlStoredEndpointBuilderFactory.java | 5 +-
.../endpoint/dsl/StripeEndpointBuilderFactory.java | 3 +-
.../dsl/TwitterTimelineEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/VertxEndpointBuilderFactory.java | 24 +-
dsl/camel-jbang/camel-jbang-core/pom.xml | 5 +-
.../camel/dsl/jbang/core/commands/Debug.java | 1 +
.../apache/camel/dsl/jbang/core/commands/Run.java | 83 +++-
.../dsl/jbang/core/commands/ai/AuthoringTools.java | 50 ++-
.../core/commands/ai/IntegrationLauncher.java | 62 ++-
.../jbang/core/commands/ai/SourceValidator.java | 59 ++-
.../dsl/jbang/core/commands/ai/ToolRegistry.java | 29 +-
.../camel/dsl/jbang/core/common/ExampleHelper.java | 60 +--
.../test/file-processing.citrus.it.yaml | 26 ++
.../http-client/test/http-client.citrus.it.yaml | 21 ++
.../stock-api/test/stock-api.citrus.it.yaml | 49 +++
.../test/openapi-client.citrus.it.yaml | 39 ++
.../test/openapi-server.citrus.it.yaml | 76 ++++
.../test/rest-code-first.citrus.it.yaml | 95 +++++
.../test/circuit-breaker.citrus.it.yaml | 26 ++
.../test/error-handling.citrus.it.yaml | 36 ++
.../rest-api/test/rest-api.citrus.it.yaml | 40 ++
.../quick-start/routes/test/routes.citrus.it.yaml | 19 +
.../splitter/test/splitter.citrus.it.yaml | 19 +
.../timer-log/test/timer-log.citrus.it.yaml | 16 +
.../aggregator/test/aggregator.citrus.it.yaml | 25 ++
.../test/content-based-router.citrus.it.yaml | 30 ++
.../test/dynamic-routing.citrus.it.yaml | 35 ++
.../test/enrich-and-dedupe.citrus.it.yaml | 34 ++
.../test/filter-and-multicast.citrus.it.yaml | 30 ++
.../order-lines/test/order-lines.citrus.it.yaml | 25 ++
.../test/nightly-report.citrus.it.yaml | 16 +
.../test/order-generator.citrus.it.yaml | 24 ++
.../test/properties-and-profiles.citrus.it.yaml | 16 +
.../csv-to-json/test/csv-to-json.citrus.it.yaml | 21 ++
.../data-mapping/test/data-mapping.citrus.it.yaml | 24 ++
.../transform/groovy/test/groovy.citrus.it.yaml | 24 ++
.../test/json-transform.citrus.it.yaml | 23 ++
.../xml-to-json/test/xml-to-json.citrus.it.yaml | 16 +
.../transform/xslt/test/xslt.citrus.it.yaml | 23 ++
.../dsl/jbang/core/commands/CliHelpGoldenTest.java | 4 +-
.../core/commands/CommandInputErrorsTest.java | 25 ++
.../dsl/jbang/core/commands/RunDirectoryTest.java | 16 +
.../camel/dsl/jbang/core/commands/RunTest.java | 21 ++
.../core/commands/ai/AuthoringToolsCitrusTest.java | 221 +++++++++++
.../core/commands/ai/ExampleToolsRegistryTest.java | 54 ++-
.../core/commands/ai/IntegrationLauncherTest.java | 70 ++++
.../dsl/jbang/core/common/ExampleHelperTest.java | 29 ++
.../jbang/core/common/ExampleRoutesLoadTest.java | 6 +-
.../golden/citrus/test/orders.citrus.it.yaml | 22 ++
.../src/test/resources/golden/cli-help.txt | 19 +-
.../jbang/core/commands/mcp/AuthoringTools.java | 2 +-
.../dsl/jbang/core/commands/mcp/ExampleTools.java | 9 +-
.../core/commands/mcp/McpServerInstructions.java | 4 +
.../core/commands/mcp/AuthoringToolsTest.java | 24 ++
.../jbang/core/commands/mcp/ExampleToolsTest.java | 16 +
.../commands/mcp/McpServerInstructionsTest.java | 16 +
.../org/apache/camel/dsl/jbang/run/RunFiles.java | 114 +++++-
.../apache/camel/dsl/jbang/run/RunFilesTest.java | 122 ++++++
.../camel/dsl/yaml/validator/TextBodyFlowTest.java | 12 +-
parent/pom.xml | 2 +-
.../rocketmq/services/RocketMQBrokerContainer.java | 72 +++-
417 files changed, 12334 insertions(+), 1149 deletions(-)
create mode 100644
components/camel-atmosphere-websocket/src/test/java/org/apache/camel/component/atmosphere/websocket/WebsocketQueryParameterTest.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/stream/Ai21StreamParser.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/runtime/stream/NovaStreamParser.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/test/java/org/apache/camel/component/aws2/bedrock/agentruntime/BedrockAgentRuntimeProducerOperationTest.java
create mode 100644
components/camel-aws/camel-aws-bedrock/src/test/java/org/apache/camel/component/aws2/bedrock/runtime/BedrockProducerRequestTest.java
create mode 100644
components/camel-aws/camel-aws2-athena/src/test/java/org/apache/camel/component/aws2/athena/Athena2ProducerResultHeadersTest.java
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-bonita/src/main/java/org/apache/camel/component/bonita/BonitaConstants.java}
(69%)
create mode 100644
components/camel-bonita/src/test/java/org/apache/camel/component/bonita/BonitaStartProducerTest.java
create mode 100644
components/camel-cxf/camel-cxf-rest/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsConsumerUnchangedBodyTest.java
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/BodyTypeService.java}
(65%)
create mode 100644
components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfBodyTypesTest.java
create mode 100644
components/camel-debezium/camel-debezium-mongodb/src/test/java/org/apache/camel/component/debezium/mongodb/DebeziumMongodbEndpointTest.java
create mode 100644
components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/DataSetRow.java
create mode 100644
components/camel-flatpack/src/test/java/org/apache/camel/component/flatpack/FlatpackSplitRowsTest.java
create mode 100644
components/camel-flink/src/test/java/org/apache/camel/component/flink/DataStreamComponentOptionsAndCollectTest.java
create mode 100644
components/camel-flowable/src/test/java/org/apache/camel/component/flowable/FlowableProducerChannelNotDeployedTest.java
create mode 100644
components/camel-flowable/src/test/resources/channel/userRouteChannel.channel
create mode 100644
components/camel-fop/src/test/java/org/apache/camel/component/fop/FopBodyTest.java
create mode 100644
components/camel-hivemq/src/test/java/org/apache/camel/component/hivemq/HiveMQProducerBodyTest.java
create mode 100644
components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyMessageBodyTest.java
create mode 100644
components/camel-jooq/src/test/java/org/apache/camel/component/jooq/JooqProducerEmptyBodyTest.java
create mode 100644
components/camel-jt400/src/test/java/org/apache/camel/component/jt400/Jt400PgmProducerTest.java
create mode 100644
components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisInOutKeepsBodyTest.java
create mode 100644
components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisNullBodyTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyDefaultCodecReplyTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyProducerSyncFalseReplyTest.java
create mode 100644
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseByteBufTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerConfigFileSolverManagerTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerConsumerCamelContextTest.java
create mode 100644
components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerSyncConsumerTest.java
create mode 100644
components/camel-optaplanner/src/test/resources/org/apache/camel/component/optaplanner/solverConfigQuick.xml
copy
components/{camel-spring-parent/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchConstants.java
=>
camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConstants.java}
(57%)
create mode 100644
components/camel-pg-replication-slot/src/test/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotConsumerTest.java
create mode 100644
components/camel-robotframework/src/test/java/org/apache/camel/component/robotframework/RobotFrameworkConsumerTest.java
create mode 100644
components/camel-robotframework/src/test/resources/org/apache/camel/component/robotframework/set_variable_camel_no_body.robot
create mode 100644
components/camel-rss/src/test/java/org/apache/camel/component/rss/RssEntryCloneFailureTest.java
create mode 100644
components/camel-servicenow/camel-servicenow-component/src/test/java/org/apache/camel/component/servicenow/ServiceNowUnwrapTest.java
create mode 100644
components/camel-smooks/src/test/java/org/apache/camel/component/smooks/SmooksReaderBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ws/src/test/java/org/apache/camel/component/spring/ws/ConsumerReplyBodyTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ws/src/test/resources/org/apache/camel/component/spring/ws/ConsumerReplyBodyTest-context.xml
create mode 100644
components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerBatchTest.java
create mode 100644
components/camel-stripe/src/test/java/org/apache/camel/component/stripe/StripeProducerRequestTest.java
create mode 100644
components/camel-test/camel-test-citrus/src/test/java/org/apache/camel/component/citrus/CitrusValidateBodyTypesTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/DirectMessageProducerTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/TwitterConverterTest.java
create mode 100644
components/camel-twitter/src/test/java/org/apache/camel/component/twitter/TwitterTimelineEndpointTest.java
create mode 100644
components/camel-undertow/src/test/java/org/apache/camel/component/undertow/UndertowBodyConversionTest.java
create mode 100644
components/camel-vertx/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxBodyHelper.java
create mode 100644
components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyStreamTest.java
create mode 100644
components/camel-whatsapp/src/test/java/org/apache/camel/component/whatsapp/WhatsAppWebhookProcessorTest.java
create mode 100644
components/camel-zendesk/src/test/java/org/apache/camel/component/zendesk/ZendeskApiNameTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/connect/file-processing/test/file-processing.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/connect/http-client/test/http-client.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/connect/stock-api/test/stock-api.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/contracts/openapi-client/test/openapi-client.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/contracts/openapi-server/test/openapi-server.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/contracts/rest-code-first/test/rest-code-first.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/fail-well/circuit-breaker/test/circuit-breaker.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/fail-well/error-handling/test/error-handling.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/rest-api/test/rest-api.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/routes/test/routes.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/splitter/test/splitter.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/quick-start/timer-log/test/timer-log.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/aggregator/test/aggregator.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/content-based-router/test/content-based-router.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/dynamic-routing/test/dynamic-routing.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/enrich-and-dedupe/test/enrich-and-dedupe.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/filter-and-multicast/test/filter-and-multicast.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/route/order-lines/test/order-lines.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/run/nightly-report/test/nightly-report.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/run/order-generator/test/order-generator.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/run/properties-and-profiles/test/properties-and-profiles.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/csv-to-json/test/csv-to-json.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/data-mapping/test/data-mapping.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/groovy/test/groovy.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/json-transform/test/json-transform.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/xml-to-json/test/xml-to-json.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/main/resources/examples/transform/xslt/test/xslt.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/java/org/apache/camel/dsl/jbang/core/commands/ai/AuthoringToolsCitrusTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/golden/citrus/test/orders.citrus.it.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-run/src/test/java/org/apache/camel/dsl/jbang/run/RunFilesTest.java
