This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch feature/CAMEL-24961-body-types-saas-2
in repository https://gitbox.apache.org/repos/asf/camel.git
discard 5ccffa90e985 CAMEL-24961: Catalog body types for dhis2,
twitter-directmessage, twitter-search, twitter-timeline, sap-netweaver,
geocoder, xchange, web3j, splunk-hec, stitch, olingo2, olingo4 and odata
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 45938ab5d62a CAMEL-24961: Catalog body types for dhis2,
twitter-directmessage, twitter-search, twitter-timeline, sap-netweaver,
geocoder, xchange, web3j, splunk-hec, stitch, olingo2, olingo4 and odata
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 (5ccffa90e985)
\
N -- N -- N refs/heads/feature/CAMEL-24961-body-types-saas-2
(45938ab5d62a)
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:
.../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 +-
.../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 +-
.../component/quickfixj/MessageCorrelator.java | 25 +-
.../component/quickfixj/QuickfixjProducer.java | 16 +-
.../QuickfixjProducerCorrelationCleanupTest.java | 130 +++++
.../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 +-
106 files changed, 7175 insertions(+), 366 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
