This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch quick-fix/quickjs-stale-result
in repository https://gitbox.apache.org/repos/asf/camel.git
from efe1c49e3131 chore: camel-quickjs - fail a script result that cannot
reach Java instead of returning the previous result
add 20c94435789e CAMEL-25872: camel-kafka-share - consume again after the
CamelContext is suspended and resumed (#28386)
add d44150e4ad22 CAMEL-25867: camel-mail - mimeMultipart unmarshal with
headersInline keeps the start of a stream-cached body (#28384)
add 9141da28a7da CAMEL-25859: camel-mongodb-gridfs - the consumer routes
each found file with its own content (#28381)
add 688db726024e CAMEL-25857: camel-kubernetes - watch consumers try again
when their first watch cannot be created (#28380)
add 76c81755f256 CAMEL-25855: camel-quickfix - remove the correlation rule
of an InOut request that got no reply (#28378)
add 4c4f6fb96190 CAMEL-25941: camel-as2 - support sending through an HTTP
proxy (#28265)
add fd349d4f34cd CAMEL-16039: camel-sjms - Reinstate Batch JMS Processing
(#27173)
add b62e90ddb2d9 CAMEL-25869: camel-pulsar - a consumer that cannot
subscribe fails the start of the route (#28385)
add fc2a4df2e076 CAMEL-25186: camel-jbang - Export should resolve the
delegate endpoint of a master: endpoint (#28370)
add b418ab6acd42 CAMEL-25912: camel-milo - client producers no longer wait
for the manager lock or rebuild the connection (#28371)
add a23cf115d4fd chore: camel-jbang - fix the SourceSizeTest failure on
main: SourceTab.java is over 2000 lines (#28419)
add 1e5dded30551 CAMEL-26115: camel-datasonnet, camel-hl7,
camel-openfeature, camel-ognl, camel-python, camel-quickjs, camel-javascript,
camel-python3 - small bugs of the languages
add 4e05d6b7dbe7 CAMEL-26115: camel-quickjs - a DataView result becomes a
List of its bytes, not an empty Map
add 1984d34ecbc2 CAMEL-26115: camel-python - a dict or list that holds
itself is copied once instead of overflowing the stack
add 6fc99505d683 Merge branch 'fix/CAMEL-26115-language-bugs' into
quick-fix/quickjs-stale-result
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/as2.json | 40 +-
.../org/apache/camel/catalog/components/sjms.json | 10 +-
.../org/apache/camel/catalog/components/sjms2.json | 10 +-
.../apache/camel/catalog/docs/as2-component.adoc | 36 ++
.../camel/catalog/docs/milo-client-component.adoc | 6 +-
.../camel/catalog/docs/quickjs-language.adoc | 8 +-
.../apache/camel/catalog/docs/sjms-component.adoc | 55 +++
.../apache/camel/catalog/docs/sjms2-component.adoc | 55 +++
.../org/apache/camel/catalog/docs/test-dst.adoc | 4 +-
.../component/as2/api/AS2ClientConnection.java | 95 +++-
...rverManagerEndpointConfigurationConfigurer.java | 28 ++
...ientManagerEndpointConfigurationConfigurer.java | 28 ++
.../component/as2/AS2ConfigurationConfigurer.java | 28 ++
.../camel/component/as2/AS2EndpointConfigurer.java | 28 ++
.../camel/component/as2/AS2EndpointUriFactory.java | 10 +-
...rverManagerEndpointConfigurationConfigurer.java | 28 ++
.../org/apache/camel/component/as2/as2.json | 40 +-
.../src/main/docs/as2-component.adoc | 36 ++
.../camel/component/as2/AS2Configuration.java | 53 +++
.../as2/internal/AS2ConnectionHelper.java | 3 +-
.../camel/component/as2/AS2ClientProxyTest.java | 452 ++++++++++++++++++
.../apache/camel/component/as2/TestHttpProxy.java | 238 ++++++++++
.../component/kafka/AbstractKafkaComponent.java | 55 ++-
.../component/kafka/share/KafkaShareConsumer.java | 10 +-
.../share/KafkaShareConsumerSuspendResumeTest.java | 119 +++++
.../camel/component/kafka/KafkaConsumer.java | 10 +-
.../component/kubernetes/KubernetesHelper.java | 32 +-
.../config_maps/KubernetesConfigMapsConsumer.java | 2 +-
.../KubernetesCustomResourcesConsumer.java | 2 +-
.../deployments/KubernetesDeploymentsConsumer.java | 2 +-
.../events/KubernetesEventsConsumer.java | 2 +-
.../kubernetes/hpa/KubernetesHPAConsumer.java | 2 +-
.../namespaces/KubernetesNamespacesConsumer.java | 2 +-
.../kubernetes/nodes/KubernetesNodesConsumer.java | 2 +-
.../kubernetes/pods/KubernetesPodsConsumer.java | 2 +-
.../KubernetesReplicationControllersConsumer.java | 2 +-
.../services/KubernetesServicesConsumer.java | 2 +-
.../OpenshiftDeploymentConfigsConsumer.java | 2 +-
.../KubernetesPodsConsumerFirstWatchFailsTest.java | 96 ++++
.../mime/multipart/MimeMultipartDataFormat.java | 6 +-
.../MimeMultipartInlineHeadersStreamCacheTest.java | 117 +++++
.../src/main/docs/milo-client-component.adoc | 6 +-
.../milo/client/MiloClientConnection.java | 15 +-
.../milo/client/internal/SubscriptionManager.java | 173 ++++---
.../component/milo/MiloClientExecutorTest.java | 7 +-
.../milo/ProducerOnSharedConnectionTest.java | 433 +++++++++++++++++
.../org/apache/camel/component/milo/TcpRelay.java | 28 +-
.../client/MiloClientProducerWriteFailureTest.java | 2 +-
...ubscriptionManagerExceptionPropagationTest.java | 4 +-
.../component/mongodb/gridfs/GridFsConsumer.java | 3 +-
.../gridfs/GridFsConsumerTimestampTest.java | 44 +-
components/camel-pulsar/pom.xml | 5 +
.../consumers/CommonCreationStrategyImpl.java | 43 ++
.../utils/consumers/FailoverConsumerStrategy.java | 30 +-
.../utils/consumers/KeySharedConsumerStrategy.java | 30 +-
.../utils/consumers/SharedConsumerStrategy.java | 30 +-
.../pulsar/PulsarConsumerSubscribeFailureTest.java | 99 ++++
.../camel/component/pulsar/dst/FakePulsar.java | 525 +++++++++++++++++++++
.../pulsar/dst/PulsarConsumerDstTest.java | 49 ++
.../camel/component/pulsar/dst/PulsarWorld.java | 254 ++++++++++
.../src/test/resources/log4j2.properties | 10 +-
.../camel/language/python/PythonExpression.java | 25 +-
.../camel/language/python/PythonResultTest.java | 10 +
.../component/quickfixj/MessageCorrelator.java | 25 +-
.../component/quickfixj/QuickfixjProducer.java | 16 +-
.../QuickfixjProducerCorrelationCleanupTest.java | 130 +++++
.../src/main/docs/quickjs-language.adoc | 8 +-
.../camel/language/quickjs/QuickjsHelper.java | 11 +-
.../language/quickjs/QuickjsSerializationTest.java | 8 +
.../component/sjms/SjmsEndpointConfigurer.java | 15 +
.../component/sjms/SjmsEndpointUriFactory.java | 5 +-
.../org/apache/camel/component/sjms/sjms.json | 10 +-
.../camel-sjms/src/main/docs/sjms-component.adoc | 55 +++
.../apache/camel/component/sjms/SjmsConstants.java | 4 +
.../apache/camel/component/sjms/SjmsEndpoint.java | 103 ++++
.../sjms/consumer/BatchConsumerWorker.java | 189 ++++++++
.../consumer/BatchConsumerWorkerException.java | 29 ++
.../consumer/BatchEndpointMessageListener.java | 145 ++++++
.../consumer/BatchMessageListenerContainer.java | 168 +++++++
.../consumer/SimpleMessageListenerContainer.java | 18 +-
.../sjms/batch/BatchConcurrentConsumerTest.java | 95 ++++
.../sjms/batch/BatchConsumerBatchSizeTest.java | 63 +++
.../batch/BatchConsumerExceptionHandlerTest.java | 108 +++++
.../sjms/batch/BatchConsumerIntervalTest.java | 99 ++++
.../sjms/batch/BatchConsumerJmsSelectorTest.java | 85 ++++
.../sjms/batch/BatchConsumerPoisonMessageTest.java | 124 +++++
.../sjms/batch/BatchConsumerReconnectTest.java | 175 +++++++
.../BatchConsumerRecoveryFailedAttemptTest.java | 235 +++++++++
.../sjms/batch/BatchConsumerRecoveryTest.java | 109 +++++
.../sjms/batch/BatchConsumerRollbackOnlyTest.java | 134 ++++++
.../sjms/batch/BatchConsumerStopStartTest.java | 235 +++++++++
.../sjms/batch/BatchConsumerTransactedTest.java | 132 ++++++
.../sjms/batch/BatchConsumerValidationTest.java | 91 ++++
.../component/sjms/batch/BatchTestHelper.java | 377 +++++++++++++++
.../component/sjms2/Sjms2EndpointUriFactory.java | 5 +-
.../org/apache/camel/component/sjms2/sjms2.json | 10 +-
.../camel-sjms2/src/main/docs/sjms2-component.adoc | 55 +++
.../sjms2/batch/BatchConsumerTransactedTest.java | 175 +++++++
.../batch/InOnlyTopicDurableBatchConsumerTest.java | 106 +++++
.../batch/InOnlyTopicSharedBatchConsumerTest.java | 113 +++++
.../camel-test-dst/src/main/docs/test-dst.adoc | 4 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 37 +-
.../endpoint/dsl/AS2EndpointBuilderFactory.java | 75 +++
.../endpoint/dsl/Sjms2EndpointBuilderFactory.java | 116 +++++
.../endpoint/dsl/SjmsEndpointBuilderFactory.java | 116 +++++
.../camel/dsl/jbang/core/commands/ExportTest.java | 30 ++
.../src/test/resources/master-route.yaml | 22 +
.../jbang/core/commands/tui/SourceEmptyLines.java | 83 ++++
.../dsl/jbang/core/commands/tui/SourceTab.java | 51 +-
.../core/commands/tui/OpenedProjectViewsTest.java | 4 +-
.../java/org/apache/camel/main/KameletMain.java | 2 +-
.../main/download/DownloadEndpointStrategy.java | 23 +-
112 files changed, 7226 insertions(+), 385 deletions(-)
create mode 100644
components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/AS2ClientProxyTest.java
create mode 100644
components/camel-as2/camel-as2-component/src/test/java/org/apache/camel/component/as2/TestHttpProxy.java
create mode 100644
components/camel-kafka-share/src/test/java/org/apache/camel/component/kafka/share/KafkaShareConsumerSuspendResumeTest.java
create mode 100644
components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesPodsConsumerFirstWatchFailsTest.java
create mode 100644
components/camel-mail/src/test/java/org/apache/camel/dataformat/mime/multipart/MimeMultipartInlineHeadersStreamCacheTest.java
create mode 100644
components/camel-milo/src/test/java/org/apache/camel/component/milo/ProducerOnSharedConnectionTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerSubscribeFailureTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/dst/FakePulsar.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/dst/PulsarConsumerDstTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/dst/PulsarWorld.java
create mode 100644
components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjProducerCorrelationCleanupTest.java
create mode 100644
components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/BatchConsumerWorker.java
create mode 100644
components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/BatchConsumerWorkerException.java
create mode 100644
components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/BatchEndpointMessageListener.java
create mode 100644
components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/BatchMessageListenerContainer.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConcurrentConsumerTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerBatchSizeTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerExceptionHandlerTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerIntervalTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerJmsSelectorTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerPoisonMessageTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerReconnectTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerRecoveryFailedAttemptTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerRecoveryTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerRollbackOnlyTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerStopStartTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerTransactedTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchConsumerValidationTest.java
create mode 100644
components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/BatchTestHelper.java
create mode 100644
components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/batch/BatchConsumerTransactedTest.java
create mode 100644
components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/batch/InOnlyTopicDurableBatchConsumerTest.java
create mode 100644
components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/batch/InOnlyTopicSharedBatchConsumerTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/master-route.yaml
create mode 100644
dsl/camel-jbang/camel-jbang-plugin-tui/src/main/java/org/apache/camel/dsl/jbang/core/commands/tui/SourceEmptyLines.java
