You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by nf...@apache.org on 2022/04/13 13:02:00 UTC
[camel] branch CAMEL-17921/hazelcast-operations-misspelled updated (92fe8f825f6 -> 1b0608e2d91)
This is an automated email from the ASF dual-hosted git repository.
nfilotto pushed a change to branch CAMEL-17921/hazelcast-operations-misspelled
in repository https://gitbox.apache.org/repos/asf/camel.git
discard 92fe8f825f6 CAMEL-17921: Fix misspelled Hazelcast operations
add c596eb135cf CAMEL-17763: cleaned up unused exceptions in camel-lra
add e84e878d54f CAMEL-17763: cleaned up unused exceptions in camel-leveldb
add 3d46ff3b6ac CAMEL-17763: cleaned up unused exceptions in camel-ldif
add de5257e63cb CAMEL-17763: cleaned up unused exceptions in camel-ldap
add 3bdb5079bf5 CAMEL-17763: cleaned up unused exceptions in camel-kudu
add d0512e1aa88 CAMEL-17763: cleaned up unused exceptions in camel-kubernetes
add dfdb5969a67 CAMEL-17763: cleaned up unused exceptions in camel-kamelet
add 9f550dc8b3d CAMEL-17763: cleaned up unused exceptions in camel-jt400
add 284feaeab3b CAMEL-17763: cleaned up unused exceptions in camel-jsonb
add d6194e92ca0 CAMEL-17912: camel-sjms - Add preserveMessageQos code in producer which was missing (copy from camel-jms)
add 3e9e8573973 CAMEL-17763: cleaned up unused exceptions in camel-jolt
add 44e5a9d70e0 CAMEL-17763: cleaned up unused exceptions in camel-johnzon
add 1a3ea952f3a CAMEL-17763: cleaned up unused exceptions in camel-jmx
add 36ff6e90790 CAMEL-17763: cleaned up unused exceptions in camel-jms
add 4e4868d25bc CAMEL-17763: cleaned up unused exceptions in camel-jira
add 2ff5e5b9963 CAMEL-17763: cleaned up unused exceptions in camel-jgroups
add 39fb50836d7 CAMEL-17763: cleaned up unused exceptions in camel-jgroups-raft
add 7131ff9f059 CAMEL-17763: cleaned up unused exceptions in camel-jetty
add b36aea5dec9 CAMEL-17763: cleaned up unused exceptions in camel-jdbc
add f9ac8e12359 CAMEL-17763: cleaned up unused exceptions in camel-jcr
add e78bb64e544 CAMEL-17763: cleaned up unused exceptions in camel-jsonata
add a63800ff07b CAMEL-17763: cleaned up unused exceptions in camel-jsonapi
add 74ba3dbab3b CAMEL-17763: cleaned up unused exceptions in camel-json-validator
add a9ca9fd2d04 CAMEL-17763: cleaned up unused exceptions in camel-json-patch
add 8c2491ce139 CAMEL-17763: cleaned up unused exceptions in camel-jslt
add 5ccc5244cf9 CAMEL-17763: cleaned up unused exceptions in camel-jsch
add 3a1f6c8ed1d CAMEL-17763: cleaned up unused exceptions in camel-jpa
add 1484dd3c125 CAMEL-17763: cleaned up unused exceptions in camel-joor
add abdb6e9bb21 CAMEL-17763: cleaned up unused exceptions in camel-jooq
add 6c555f27ffd CAMEL-17763: cleaned up unused exceptions in camel-mllp
add e97f0368942 CAMEL-17763: cleaned up unused exceptions in camel-mongodb-gridfs
add 8d557c73fd9 CAMEL-17763: cleaned up unused exceptions in camel-minio
add a27765e8094 CAMEL-17763: cleaned up unused exceptions in camel-mina
add 6381f15ec10 CAMEL-17763: cleaned up unused exceptions in camel-milo
add 1b5b92c5b25 CAMEL-17763: cleaned up unused exceptions in camel-master
add 386aa1b339d CAMEL-17763: cleaned up unused exceptions in camel-lzf
add b560ac83f7f CAMEL-17763: cleaned up unused exceptions in camel-lumberjack
add b317d0d21fe CAMEL-17763: cleaned up unused exceptions in camel-lucene
add d04c3ca9614 CAMEL-17763: cleaned up unused exceptions in camel-sap-netweaver
add 6ed996c3bcc CAMEL-17763: cleaned up unused exceptions in camel-rxjava
add c35bc278b4a CAMEL-17763: cleaned up unused exceptions in camel-rss
add 486e7b4194d CAMEL-17763: cleaned up unused exceptions in camel-robotframework
add d3782803cd6 CAMEL-17763: cleaned up unused exceptions in camel-resteasy
add c808eafb7cf CAMEL-17763: cleaned up unused exceptions in camel-rest-swagger
add acfff12ce01 CAMEL-17763: cleaned up unused exceptions in camel-rest-openapi
add 369bbffb4c6 CAMEL-17763: cleaned up unused exceptions in camel-resourceresolver-github
add 026a215a2bd CAMEL-17763: cleaned up unused exceptions in camel-resilience4j
add 2f68a771483 CAMEL-17763: cleaned up unused exceptions in camel-reactor
add 9b98c6ab880 CAMEL-17763: cleaned up unused exceptions in camel-reactive-streams
add d0b9caafa6e CAMEL-17763: cleaned up unused exceptions in camel-reactive-executor-vertx
add 7dc30b55000 CAMEL-17763: cleaned up unused exceptions in camel-quickfix
add 3de0b70999c CAMEL-17763: cleaned up unused exceptions in camel-quartz
add 3481438341e CAMEL-17763: cleaned up unused exceptions in camel-pubnub
add e7037617c0d CAMEL-17763: cleaned up unused exceptions in camel-protobuf
add f7c1ee08832 CAMEL-17763: cleaned up unused exceptions in camel-printer
add a634746e7f8 CAMEL-17763: cleaned up unused exceptions in camel-pgevent
add 0b7768b8cb8 Regen
add ddffb095050 Upgrade AWS SDK v2 to version 2.17.169
add ee4bcccbc01 Sync and regen
add 76fc7c12980 Regen for commit ee4bcccbc01c973c2a0a7600091256e2427a203a (#7429)
add 792a767c82b CAMEL-17957 CXF import range too restrictive in OSGi
add 292c22f819e CAMEL-17763: cleaned up unused exceptions in camel-rabbitmq
add 2104db00ebe CAMEL-17763: cleaned up unused exceptions in camel-onlingo4
add 8fce1b0c48c CAMEL-17763: cleaned up unused exceptions in camel-onlingo2
add 13bf9bf5695 CAMEL-17763: cleaned up unused exceptions in camel-mybatis
add db60c71bc42 CAMEL-17763: cleaned up unused exceptions in camel-mvel
add 64db60a702b CAMEL-17763: cleaned up unused exceptions in camel-microprofile
add 99c3d2707f2 CAMEL-17763: cleaned up unused exceptions in camel-schematron
add 154aabe1286 CAMEL-17763: cleaned up unused exceptions in camel-saxon
add 4fc0965d9f7 CAMEL-17763: cleaned up unused exceptions in camel-pdf
add 32df1f83d7d CAMEL-17763: cleaned up unused exceptions in camel-optaplanner
add 3785e014e22 CAMEL-17763: cleaned up unused exceptions in camel-opentracing
add 9fc41caf67d CAMEL-17763: cleaned up unused exceptions in camel-opentelemetry
add d1895acf2cf CAMEL-17763: cleaned up unused exceptions in camel-openstack
add 215151662f4 CAMEL-17763: cleaned up unused exceptions in camel-openapi-java
add 1973aa7f5d1 CAMEL-17763: cleaned up unused exceptions in camel-ognl
add 3e8ef32959e CAMEL-17763: cleaned up unused exceptions in camel-nitrite
add 28d143047e1 Regen for commit 792a767c82b058f375aa4761c4bb8541eb3e9a26
add 2de2764a687 CAMEL-17051: extend the Resume API to include support for pausable consumers
add 92e6b430b0f CAMEL-17948: Wait for completion on reset (#7430)
add 87baed64372 CAMEL-17763: cleaned up unused exceptions in camel-nats
add 2322e3ad33a CAMEL-17961: Re-add the JS file for the documentation
add ee6e0e5b36f CAMEL-17763: cleaned up unused exceptions in camel-stringtemplate
add ff7b18b25c2 CAMEL-17763: cleaned up unused exceptions in camel-stream
add 11d02f9f699 CAMEL-17763: cleaned up unused exceptions in camel-stitch
add 56a05417792 CAMEL-17763: cleaned up unused exceptions in camel-splunk
add e82747fb931 CAMEL-17763: cleaned up unused exceptions in camel-splunk-hec
add 0435914e083 CAMEL-17763: cleaned up unused exceptions in camel-snmp
add 1f1a1ee0829 CAMEL-17763: cleaned up unused exceptions in camel-smpp
add 368b5f5dee0 CAMEL-17763: cleaned up unused exceptions in camel-slack
add 743f8240b5b CAMEL-17763: cleaned up unused exceptions in camel-servicenow
add 68da92aec85 CAMEL-17763: cleaned up unused exceptions in camel-shiro
add ce355707222 CAMEL-17763: cleaned up unused exceptions in camel-vertx
add 1b0608e2d91 CAMEL-17921: Fix misspelled Hazelcast operations
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 (92fe8f825f6)
\
N -- N -- N refs/heads/CAMEL-17921/hazelcast-operations-misspelled (1b0608e2d91)
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:
camel-dependencies/pom.xml | 4 +-
.../apache/camel/catalog/components/aws2-ec2.json | 2 +-
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../org/apache/camel/catalog/models.properties | 1 +
.../org/apache/camel/catalog/models/pausable.json | 20 ++
.../apache/camel/catalog/schemas/camel-spring.xsd | 50 +++++
.../apache/camel/component/aws2/ec2/aws2-ec2.json | 2 +-
.../component/jcr/JcrAuthLoginFailureTest.java | 6 +-
.../camel/component/jcr/JcrAuthLoginTest.java | 4 +-
.../camel/component/jcr/JcrConverterTest.java | 10 +-
.../camel/component/jcr/JcrGetNodeByIdTest.java | 4 +-
.../component/jcr/JcrNodePathCreationTest.java | 4 +-
.../jcr/JcrProducerDifferentWorkspaceTest.java | 4 +-
.../component/jcr/JcrProducerSubNodeTest.java | 4 +-
.../camel/component/jcr/JcrProducerTest.java | 4 +-
.../jdbc/AbstractJdbcGeneratedKeysTest.java | 8 +-
.../JdbcParameterizedQueryGeneratedKeysTest.java | 8 +-
.../camel/component/jetty/BaseJettyTest.java | 2 +-
.../jetty/ConvertPayloadToInputStreamTest.java | 2 +-
.../camel/component/jetty/CustomFiltersTest.java | 10 +-
.../camel/component/jetty/EnableCORSTest.java | 4 +-
.../component/jetty/ExcludeCipherSuitesTest.java | 4 +-
.../component/jetty/ExplicitHttpsRouteTest.java | 9 +-
...ExplicitHttpsSslContextParametersRouteTest.java | 6 +-
.../jetty/ExplicitJettyAsyncRouteTest.java | 8 +-
.../component/jetty/ExplicitJettyRouteTest.java | 8 +-
.../apache/camel/component/jetty/HandlerTest.java | 10 +-
.../component/jetty/HttpAcceptHeaderTest.java | 6 +-
.../jetty/HttpAuthMethodPriorityTest.java | 17 +-
.../HttpBasicAuthComponentConfiguredTest.java | 11 +-
.../camel/component/jetty/HttpBasicAuthTest.java | 13 +-
...gMapHttpMessageFormUrlEncodedFalseBodyTest.java | 6 +-
...pBindingPreservePostFormUrlEncodedBodyTest.java | 10 +-
.../camel/component/jetty/HttpBindingRefTest.java | 10 +-
.../component/jetty/HttpBridgeAsyncRouteTest.java | 4 +-
.../jetty/HttpBridgeMultipartRouteTest.java | 4 +-
.../camel/component/jetty/HttpBridgeRouteTest.java | 6 +-
.../component/jetty/HttpCharacterEncodingTest.java | 10 +-
.../jetty/HttpClientRouteEnableChunkedTest.java | 4 +-
.../camel/component/jetty/HttpClientRouteTest.java | 14 +-
.../camel/component/jetty/HttpConverterTest.java | 12 +-
.../component/jetty/HttpDeleteWithBodyTest.java | 10 +-
.../jetty/HttpEmptyQueryParameterTest.java | 4 +-
.../jetty/HttpEndpointUriEncodingIssueTest.java | 12 +-
.../jetty/HttpFilterCamelHeadersTest.java | 8 +-
.../jetty/HttpFilterNoCamelHeadersTest.java | 6 +-
.../component/jetty/HttpGZipEncodingTest.java | 12 +-
.../camel/component/jetty/HttpHeaderCaseTest.java | 6 +-
.../camel/component/jetty/HttpHeaderTest.java | 14 +-
.../component/jetty/HttpMethodRestrictTest.java | 6 +-
.../HttpOperationsFailedExceptionUriTest.java | 8 +-
.../component/jetty/HttpPollingConsumerTest.java | 10 +-
.../component/jetty/HttpProducerByteTest.java | 6 +-
.../jetty/HttpProducerConcurrentTest.java | 6 +-
.../jetty/HttpProducerConnectionCloseTest.java | 10 +-
.../jetty/HttpProducerJMXBeansIssueTest.java | 6 +-
.../jetty/HttpProducerOkStatusCodeRangeTest.java | 10 +-
.../jetty/HttpProducerQueryParamTest.java | 12 +-
.../component/jetty/HttpProducerSOTimeoutTest.java | 4 +-
.../jetty/HttpProducerSendEmptyHeaderTest.java | 4 +-
.../HttpProducerTwoParametersWithSameKeyTest.java | 12 +-
.../jetty/HttpProducerUnsafeCharsTest.java | 4 +-
.../jetty/HttpProxyRouteContentTypeTest.java | 6 +-
.../camel/component/jetty/HttpProxyRouteTest.java | 12 +-
.../jetty/HttpRedirectNoLocationTest.java | 8 +-
.../camel/component/jetty/HttpRedirectTest.java | 10 +-
.../component/jetty/HttpRequestResponseTest.java | 6 +-
...ttpReturnDataNotInputStreamConvertableTest.java | 8 +-
.../camel/component/jetty/HttpRouteTest.java | 23 ++-
.../camel/component/jetty/HttpSendFileTest.java | 8 +-
.../jetty/HttpStreamCacheFileIssueTest.java | 6 +-
.../jetty/HttpStreamCacheFileResponseTest.java | 6 +-
.../jetty/HttpStreamCacheFileStopIssueTest.java | 6 +-
.../component/jetty/HttpStreamCacheFileTest.java | 10 +-
.../camel/component/jetty/HttpToFileTest.java | 4 +-
.../camel/component/jetty/HttpTwoEndpointTest.java | 8 +-
.../component/jetty/HttpTwoServerPortsTest.java | 10 +-
.../camel/component/jetty/HttpsAsyncRouteTest.java | 9 +-
.../HttpsRouteAddSslConnectorPropertiesTest.java | 4 +-
.../camel/component/jetty/HttpsRouteAliasTest.java | 8 +-
.../jetty/HttpsRouteSetupWithSystemPropsTest.java | 4 +-
...psRouteSslContextParametersInComponentTest.java | 8 +-
.../HttpsRouteSslContextParametersInUriTest.java | 10 +-
.../camel/component/jetty/HttpsRouteTest.java | 9 +-
.../HttpsRouteWithSslConnectorPropertiesTest.java | 4 +-
.../camel/component/jetty/InterfacesTest.java | 4 +-
.../jetty/JettyCallHttpThenExceptionTest.java | 6 +-
.../component/jetty/JettyCamelHttpUrlCBRTest.java | 4 +-
.../jetty/JettyComponentMuteExceptionTest.java | 4 +-
.../jetty/JettyComponentSpringConfiguredTest.java | 2 +-
.../jetty/JettyContentBasedRouteTest.java | 4 +-
.../component/jetty/JettyContentTypeTest.java | 12 +-
.../jetty/JettyContinuationDisabledTest.java | 4 +-
.../camel/component/jetty/JettyEnableJmxTest.java | 6 +-
.../JettyEndpointContinuationDisabledTest.java | 4 +-
.../jetty/JettyEndpointSetHttpTraceTest.java | 4 +-
.../camel/component/jetty/JettyHandle404Test.java | 8 +-
.../jetty/JettyHttpBridgeEncodedPathTest.java | 6 +-
.../component/jetty/JettyHttpContentTypeTest.java | 4 +-
.../jetty/JettyHttpEndpointDisconnectTest.java | 6 +-
.../JettyHttpGetWithParamAsExchangeHeaderTest.java | 4 +-
.../component/jetty/JettyHttpGetWithParamTest.java | 6 +-
.../component/jetty/JettyHttpHeadersTest.java | 4 +-
.../jetty/JettyHttpMapHttpMessageHeadersTest.java | 4 +-
.../camel/component/jetty/JettyImageFileTest.java | 8 +-
.../jetty/JettyLongestContextPathMatchTest.java | 4 +-
.../component/jetty/JettyMuteExceptionTest.java | 4 +-
.../jetty/JettyOnExceptionHandledTest.java | 6 +-
.../jetty/JettyResponseBodyWhenErrorTest.java | 8 +-
.../jetty/JettyResponseBufferSizeTest.java | 6 +-
.../camel/component/jetty/JettyRouteTest.java | 10 +-
.../jetty/JettyRouteWithSocketPropertiesTest.java | 8 +-
.../JettyRouteWithUnknownSocketPropertiesTest.java | 2 +-
...ttyRouteWithUnknownSslSocketPropertiesTest.java | 2 +-
.../component/jetty/JettySessionSupportTest.java | 4 +-
.../jetty/JettySimplifiedHandle404Test.java | 6 +-
.../component/jetty/JettySimulateInOnlyTest.java | 8 +-
.../camel/component/jetty/JettySteveIssueTest.java | 4 +-
.../component/jetty/JettyStreamCacheIssueTest.java | 8 +-
.../component/jetty/JettySuspendResumeTest.java | 6 +-
.../camel/component/jetty/JettySuspendTest.java | 6 +-
.../jetty/JettySuspendWhileInProgressTest.java | 4 +-
.../jetty/JettySwitchingStatusCode204Test.java | 16 +-
.../component/jetty/JettyThreadPoolSizeTest.java | 4 +-
.../component/jetty/MultiPartFormOkHttpTest.java | 6 +-
.../camel/component/jetty/MultiPartFormTest.java | 6 +-
.../jetty/MultiPartFormWithCustomFilterTest.java | 6 +-
.../component/jetty/MultiThreadedHttpGetTest.java | 4 +-
.../jetty/SimpleJettyChunkedFalseTest.java | 6 +-
.../camel/component/jetty/SimpleJettyTest.java | 6 +-
.../component/jetty/SpringHttpsRouteTest.java | 4 +-
.../SpringJettyNoConnectionRedeliveryTest.java | 4 +-
.../jetty/SpringJettyNoConnectionTest.java | 2 +-
.../jetty/TwoCamelContextWithJettyRouteTest.java | 10 +-
.../component/jetty/async/JettyAsyncCBRTest.java | 4 +-
.../async/JettyAsyncContinuationDisabledTest.java | 4 +-
.../async/JettyAsyncContinuationTimeoutOkTest.java | 4 +-
.../async/JettyAsyncContinuationTimeoutTest.java | 4 +-
.../JettyAsyncDefaultContinuationTimeoutTest.java | 4 +-
.../jetty/async/JettyAsyncFilterTest.java | 4 +-
.../component/jetty/async/JettyAsyncTest.java | 4 +-
.../jetty/async/JettyAsyncThrottleTest.java | 4 +-
.../jetty/async/JettyAsyncTransformTest.java | 4 +-
.../jetty/async/JettyAsyncTryCatchFinallyTest.java | 4 +-
.../component/jetty/async/MyAsyncEndpoint.java | 4 +-
.../jetty/file/JettyFileConsumerTest.java | 6 +-
.../component/jetty/javabody/HttpJavaBodyTest.java | 20 +-
.../camel/component/jetty/manual/JettyManual.java | 6 +-
.../component/jetty/proxy/HttpClientProxyTest.java | 8 +-
.../HttpClientProxyTransferExceptionTest.java | 8 +-
.../jetty/proxy/JettyChuckedFalseTest.java | 8 +-
.../component/jetty/rest/RestApiJettyTest.java | 6 +-
.../component/jetty/rest/RestApiJettyYamlTest.java | 2 +-
.../jetty/rest/RestApiOverrideHostJettyTest.java | 6 +-
.../jetty/rest/RestBridgeEndpointTest.java | 4 +-
.../jetty/rest/RestHttpsClientAuthRouteTest.java | 8 +-
.../component/jetty/rest/RestJettyAcceptTest.java | 10 +-
.../jetty/rest/RestJettyBasicAuthTest.java | 2 +-
.../rest/RestJettyBindingModeAutoWithJsonTest.java | 4 +-
.../rest/RestJettyBindingModeAutoWithXmlTest.java | 4 +-
.../jetty/rest/RestJettyBindingModeJsonTest.java | 4 +-
.../RestJettyBindingModeJsonWithContractTest.java | 4 +-
.../RestJettyBindingModeOffWithContractTest.java | 4 +-
.../jetty/rest/RestJettyBindingModeXmlTest.java | 4 +-
.../jetty/rest/RestJettyContentTypeTest.java | 10 +-
.../jetty/rest/RestJettyCustomContentTypeTest.java | 12 +-
.../jetty/rest/RestJettyDefaultValueTest.java | 8 +-
.../component/jetty/rest/RestJettyGetCorsTest.java | 8 +-
.../rest/RestJettyGetCustomHttpBindingTest.java | 8 +-
.../component/jetty/rest/RestJettyGetTest.java | 8 +-
.../component/jetty/rest/RestJettyGetToDTest.java | 8 +-
.../jetty/rest/RestJettyGetWildcardsTest.java | 12 +-
...ettyInvalidJSonClientRequestValidationTest.java | 4 +-
.../jetty/rest/RestJettyMethodNotAllowedTest.java | 2 +-
.../component/jetty/rest/RestJettyOptionsTest.java | 12 +-
.../jetty/rest/RestJettyPojoInOutTest.java | 8 +-
.../jetty/rest/RestJettyPostJsonJaxbPojoTest.java | 4 +-
.../RestJettyPostJsonPojoDisableFeatureTest.java | 4 +-
.../jetty/rest/RestJettyPostJsonPojoListTest.java | 4 +-
.../jetty/rest/RestJettyPostJsonPojoTest.java | 4 +-
.../RestJettyPostNotMapHttpMessageHeadersTest.java | 6 +-
.../jetty/rest/RestJettyPostXmlJaxbPojoTest.java | 4 +-
.../rest/RestJettyRemoveAddRestAndRouteTest.java | 6 +-
.../jetty/rest/RestJettyRequiredBodyTest.java | 6 +-
.../rest/RestJettyRequiredHttpHeaderTest.java | 6 +-
.../rest/RestJettyRequiredQueryParameterTest.java | 6 +-
.../component/jetty/rest/RestJettyVerbTest.java | 8 +-
.../jetty/rest/RestNoBridgeEndpointTest.java | 4 +-
.../rest/producer/HttpRestProducerGetTest.java | 8 +-
.../rest/producer/HttpRestProducerPutTest.java | 4 +-
.../rest/producer/JettyRestProducerApiDocTest.java | 6 +-
.../rest/producer/JettyRestProducerGetTest.java | 8 +-
.../JettyRestProducerGetUriParameterTest.java | 8 +-
.../JettyRestProducerInvalidApiDocTest.java | 4 +-
.../producer/JettyRestProducerPojoInOutTest.java | 12 +-
.../rest/producer/JettyRestProducerPutTest.java | 4 +-
...JettyRestProducerThrowExceptionOnErrorTest.java | 10 +-
.../JettyRestProducerVerbUpperCaseTest.java | 8 +-
.../raft/JGroupsRaftComponentConfiguredTest.java | 2 +-
.../raft/JGroupsRaftComponentDefaultTest.java | 4 +-
.../jgroups/raft/JGroupsRaftConsumerTest.java | 4 +-
.../jgroups/raft/JGroupsRaftEndpointTest.java | 12 +-
.../jgroups/raft/JGroupsRaftProducerTest.java | 4 +-
.../JGroupsRaftClusteredRoutePolicyTest.java | 3 +-
.../raft/cluster/JGroupsRaftMasterTest.java | 2 +-
.../component/jgroups/JGroupsClusterRouteTest.java | 2 +-
.../component/jgroups/JGroupsClusterTest.java | 10 +-
.../component/jgroups/JGroupsComponentTest.java | 8 +-
.../JGroupsComponentWithChannelPropertiesTest.java | 8 +-
.../component/jgroups/JGroupsConsumerTest.java | 4 +-
.../component/jgroups/JGroupsEndpointTest.java | 8 +-
.../component/jgroups/JGroupsProducerTest.java | 4 +-
.../jgroups/JGroupsSharedChannelTest.java | 4 +-
.../jgroups/cluster/JGroupsLockMasterTest.java | 2 +-
.../jira/producer/DeleteIssueProducerTest.java | 4 +-
.../jira/producer/TransitionIssueProducerTest.java | 3 +-
.../jms/tx/XMLQueueToProcessorTransactionTest.java | 2 +-
.../jms/tx/XMLQueueToQueueTransactionTest.java | 2 +-
...sumerObserveAttributeMatchStringDifferTest.java | 4 +-
...JmxConsumerObserveAttributeMatchStringTest.java | 4 +-
.../jmx/CamelJmxConsumerObserveAttributeTest.java | 4 +-
.../camel/component/jmx/CamelJmxConsumerTest.java | 4 +-
.../camel/component/jmx/JMXComponentTest.java | 10 +-
.../camel/component/jmx/JMXConsumerTest.java | 2 +-
.../camel/component/jmx/JMXEndpointTest.java | 14 +-
.../camel/component/jmx/JMXUriBuilderTest.java | 22 +--
.../camel/component/jmx/SimpleBeanFixture.java | 4 +-
.../org/apache/camel/component/jmx/XmlFixture.java | 10 +-
.../johnzon/JohnzonJsonDataFormatTest.java | 2 +-
.../camel/component/jolt/JoltDefaultrTest.java | 4 +-
.../camel/component/jolt/JoltFirstSampleTest.java | 2 +-
.../camel/component/jolt/JoltRemovrTest.java | 4 +-
.../camel/component/jooq/JooqComponentTest.java | 2 +-
.../language/joor/JoorBeanInjectTransformTest.java | 4 +-
.../camel/language/joor/JoorBeanInjectVarTest.java | 4 +-
.../apache/camel/language/joor/JoorBeanTest.java | 4 +-
.../camel/language/joor/JoorCompileErrorTest.java | 2 +-
.../camel/language/joor/JoorCustomAliasTest.java | 4 +-
.../camel/language/joor/JoorCustomImportsTest.java | 4 +-
.../camel/language/joor/JoorLanguageTest.java | 28 +--
.../language/joor/JoorOptionalPredicateTest.java | 4 +-
.../language/joor/JoorPreCompileFalseTest.java | 4 +-
.../camel/language/joor/JoorPredicateTest.java | 4 +-
.../language/joor/JoorScriptingLanguageTest.java | 2 +-
.../language/joor/JoorStreamPredicateTest.java | 4 +-
.../language/joor/JoorTransformResourceTest.java | 4 +-
.../camel/language/joor/JoorTransformTest.java | 4 +-
.../camel/component/jpa/AbstractJpaMethodTest.java | 2 +-
.../camel/component/jpa/JpaEndpointTest.java | 10 +-
.../org/apache/camel/component/jpa/JpaTest.java | 6 +-
.../jpa/JpaWithNamedQueryAndParametersTest.java | 4 +-
.../camel/component/jpa/JpaWithNamedQueryTest.java | 4 +-
.../camel/component/jpa/QueryBuilderTest.java | 10 +-
.../camel/processor/jpa/AbstractJpaTest.java | 2 +-
.../jpa/FileConsumerJpaIdempotentTest.java | 4 +-
.../camel/processor/jpa/JpaBatchConsumerTest.java | 4 +-
.../camel/processor/jpa/JpaFlushOnSendTest.java | 2 +-
.../processor/jpa/JpaIdempotentConsumerTest.java | 6 +-
.../camel/processor/jpa/JpaNonTXRollbackTest.java | 6 +-
.../processor/jpa/JpaProducerConcurrentTest.java | 2 +-
.../camel/processor/jpa/JpaProducerNoBodyTest.java | 2 +-
.../JpaProducerWithQueryParametersHeaderTest.java | 6 +-
.../processor/jpa/JpaProducerWithQueryTest.java | 12 +-
.../camel/processor/jpa/JpaRouteEndpointTest.java | 2 +-
.../camel/processor/jpa/JpaTXRollbackTest.java | 6 +-
.../jpa/MultipleJpaRouteEndpointTest.java | 2 +-
.../camel/component/scp/ScpAlgorithmsTest.java | 4 +-
.../camel/component/scp/ScpServerTestSupport.java | 2 +-
.../camel/component/scp/ScpSimpleProduceTest.java | 4 +-
.../apache/camel/component/jslt/JsltBasicTest.java | 2 +-
.../jslt/JsltBigDecimalCustomObjectMapperTest.java | 2 +-
.../camel/component/jslt/JsltBigDecimalTest.java | 2 +-
.../camel/component/jslt/JsltFileSourceTest.java | 2 +-
.../camel/component/jslt/JsltFunctionsTest.java | 2 +-
.../camel/component/jslt/JsltObjectFilterTest.java | 2 +-
.../apache/camel/component/jslt/JsltQueryTest.java | 2 +-
.../jsonpatch/JsonPatchComponentTest.java | 4 +-
.../jsonvalidator/FileValidatorRouteTest.java | 4 +-
.../LegacyDefaultSchemaLoaderTest.java | 4 +-
.../jsonvalidator/LegacyJsonSchemaLoaderTest.java | 6 +-
.../jsonvalidator/LocalRefSchemaTest.java | 4 +-
.../jsonvalidator/ValidatorInputStreamTest.java | 4 +-
.../jsonvalidator/ValidatorRouteTest.java | 4 +-
.../component/jsonapi/JsonApiDataFormatTest.java | 10 +-
.../component/jsonata/JsonataFirstSampleTest.java | 2 +-
.../component/jsonb/JsonbJsonDataFormatTest.java | 2 +-
.../Jt400ComponentDefaultConnectionPoolTest.java | 2 +-
...00ComponentDefaultSecureConnectionPoolTest.java | 2 +-
.../camel/component/jt400/Jt400ComponentTest.java | 2 +-
.../jt400/Jt400MultipleConsumersRouteTest.java | 4 +-
.../camel/component/jt400/Jt400PgmRouteTest.java | 4 +-
.../camel/component/jt400/Jt400RouteTest.java | 4 +-
.../component/jt400/MockAS400ConnectionPool.java | 6 +-
.../jt400/MockAS400SecureConnectionPool.java | 29 ++-
components/camel-kafka/pom.xml | 18 ++
.../component/kafka/KafkaComponentConfigurer.java | 4 +-
.../component/kafka/KafkaEndpointConfigurer.java | 4 +-
.../org/apache/camel/component/kafka/kafka.json | 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 16 ++
.../camel/component/kafka/KafkaConfiguration.java | 12 +-
.../camel/component/kafka/KafkaConsumer.java | 41 ++++-
.../camel/component/kafka/KafkaFetchRecords.java | 65 +++++--
.../component/kafka/PollExceptionStrategy.java | 15 ++
.../apache/camel/component/kafka/SeekPolicy.java} | 19 +-
.../consumer/errorhandler/BridgeErrorStrategy.java | 5 +
.../errorhandler/DiscardErrorStrategy.java | 5 +
.../errorhandler/KafkaConsumerListener.java | 89 +++++++++
.../errorhandler/KafkaErrorStrategies.java | 2 +-
.../errorhandler/ReconnectErrorStrategy.java | 14 +-
.../consumer/errorhandler/RetryErrorStrategy.java | 10 +-
.../consumer/errorhandler/StopErrorStrategy.java | 13 +-
.../consumer/support/KafkaRecordProcessor.java | 4 +-
.../support/KafkaRecordProcessorFacade.java | 15 +-
.../kafka/consumer/support/ProcessingResult.java | 11 +-
.../consumer/support/ResumeStrategyFactory.java | 3 +-
.../SeekPolicyKafkaConsumerResumeStrategy.java | 9 +-
.../integration/BaseEmbeddedKafkaTestSupport.java | 10 +-
.../kafka/integration/KafkaConsumerFullIT.java | 5 +-
.../integration/pause/KafkaPausableConsumerIT.java | 203 +++++++++++++++++++++
.../src/test/resources/log4j2.properties | 2 +-
.../component/kamelet/KameletEipMulticastTest.java | 4 +-
.../apache/camel/component/KubernetesServer.java | 4 +-
.../apache/camel/component/OpenShiftServer.java | 4 +-
.../cloud/ServiceCallClientRouteTest.java | 4 +-
.../cloud/ServiceCallEnvironmentRouteTest.java | 4 +-
.../cluster/KubernetesClusterServiceTest.java | 15 +-
.../cluster/TimedLeaderNotifierTest.java | 4 +-
.../KubernetesConfigMapsConsumerIT.java | 12 +-
.../KubernetesCustomResourcesConsumerIT.java | 10 +-
.../KubernetesNamespacesConsumerIT.java | 10 +-
.../integration/KubernetesNodesConsumerIT.java | 6 +-
.../integration/KubernetesPodsConsumerIT.java | 6 +-
...KubernetesReplicationControllersConsumerIT.java | 6 +-
.../integration/KubernetesServicesConsumerIT.java | 10 +-
.../producer/KubernetesConfigMapsProducerTest.java | 14 +-
.../KubernetesCustomResourcesProducerTest.java | 6 +-
.../KubernetesDeploymentsProducerTest.java | 12 +-
.../producer/KubernetesHPAProducerTest.java | 18 +-
.../producer/KubernetesJobProducerTest.java | 10 +-
.../producer/KubernetesNamespacesProducerTest.java | 12 +-
.../producer/KubernetesNodesProducerTest.java | 12 +-
...ernetesPersistentVolumesClaimsProducerTest.java | 10 +-
.../KubernetesPersistentVolumesProducerTest.java | 8 +-
.../producer/KubernetesPodsProducerTest.java | 12 +-
...bernetesReplicationControllersProducerTest.java | 12 +-
.../KubernetesResourcesQuotaProducerTest.java | 10 +-
.../producer/KubernetesSecretsProducerTest.java | 12 +-
.../KubernetesServiceAccountsProducerTest.java | 10 +-
.../producer/KubernetesServicesProducerTest.java | 12 +-
.../OpenshiftBuildConfigsProducerTest.java | 8 +-
.../producer/OpenshiftBuildsProducerTest.java | 10 +-
.../kudu/KuduComponentConfigurationTest.java | 2 +-
.../camel/component/ldap/LdapRouteManualIT.java | 6 +-
.../camel/component/ldap/LdapRouteTwoManualIT.java | 8 +-
.../server/core/integ5/DirectoryExtension.java | 3 +-
.../core/integ5/ServerAnnotationProcessor.java | 3 +-
.../apache/camel/component/ldif/LdifRouteIT.java | 8 +-
.../server/core/integ5/DirectoryExtension.java | 3 +-
.../core/integ5/ServerAnnotationProcessor.java | 3 +-
...elDBAggregateConcurrentDifferentGroupsTest.java | 4 +-
.../LevelDBAggregateConcurrentSameGroupTest.java | 4 +-
.../LevelDBAggregateDiscardOnTimeoutTest.java | 4 +-
.../LevelDBAggregateForceCompletionHeaderTest.java | 4 +-
.../LevelDBAggregateLoadAndRecoverTest.java | 6 +-
.../LevelDBAggregateLoadConcurrentTest.java | 4 +-
.../leveldb/LevelDBAggregateLoadTest.java | 4 +-
...DBAggregateNotLostRemovedWhenConfirmedTest.java | 4 +-
.../leveldb/LevelDBAggregateNotLostTest.java | 4 +-
...ggregateRecoverDeadLetterChannelFailedTest.java | 4 +-
...velDBAggregateRecoverDeadLetterChannelTest.java | 4 +-
.../leveldb/LevelDBAggregateRecoverTest.java | 6 +-
...DBAggregateRecoverWithRedeliveryPolicyTest.java | 6 +-
.../LevelDBAggregateRecoverWithSedaTest.java | 6 +-
.../LevelDBAggregateSerializedHeadersTest.java | 4 +-
.../component/leveldb/LevelDBAggregateTest.java | 4 +-
...velDBAggregateTimeoutCompletionRestartTest.java | 4 +-
.../component/leveldb/LevelDBBigPayloadTest.java | 4 +-
.../camel/component/leveldb/LevelDBBinaryTest.java | 4 +-
.../leveldb/LevelDBCustomSerializationTest.java | 7 +-
...ngAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../camel/service/lra/AbstractLRATestSupport.java | 2 +-
.../org/apache/camel/service/lra/LRACreditIT.java | 8 +-
.../apache/camel/service/lra/LRAFailuresIT.java | 4 +-
.../org/apache/camel/service/lra/LRAManualIT.java | 4 +-
.../org/apache/camel/service/lra/LRAOptionsIT.java | 6 +-
.../org/apache/camel/service/lra/LRATimeoutIT.java | 4 +-
.../lucene/LuceneIndexAndQueryProducerIT.java | 14 +-
.../processor/lucene/LuceneQueryProcessorIT.java | 8 +-
.../LumberjackComponentLifecycleTest.java | 2 +-
.../lumberjack/LumberjackDisconnectionTest.java | 2 +-
.../camel/component/lumberjack/LumberjackUtil.java | 2 +-
.../camel/dataformat/lzf/LZFDataFormatTest.java | 2 +-
.../component/master/MasterComponentTest.java | 2 +-
.../CamelMicroProfilePropertiesSourceTest.java | 10 +-
.../FaultToleranceInheritErrorHandlerTest.java | 4 +-
.../FaultToleranceManagementTest.java | 4 +-
...tToleranceRefConfigurationNoReflectionTest.java | 4 +-
.../FaultToleranceRefConfigurationTest.java | 4 +-
.../FaultToleranceRouteBulkheadFallbackTest.java | 4 +-
.../FaultToleranceRouteBulkheadOkTest.java | 4 +-
.../FaultToleranceRouteFallbackTest.java | 4 +-
.../FaultToleranceRouteFallbackViaNetworkTest.java | 4 +-
.../faulttolerance/FaultToleranceRouteOkTest.java | 4 +-
.../FaultToleranceRouteRejectedTest.java | 4 +-
.../faulttolerance/FaultToleranceTimeoutTest.java | 10 +-
.../FaultToleranceTimeoutThreadPoolTest.java | 10 +-
.../FaultToleranceTimeoutWithFallbackTest.java | 8 +-
...CamelMicroProfileHealthCheckRepositoryTest.java | 6 +-
.../health/CamelMicroProfileHealthCheckTest.java | 2 +-
.../CamelMicroProfileHealthConsumerTest.java | 4 +-
.../MicroProfileMetricsConcurrentGaugeTest.java | 4 +-
.../metrics/MicroProfileMetricsCounterTest.java | 4 +-
.../MicroProfileMetricsCustomRegistryTest.java | 4 +-
.../metrics/MicroProfileMetricsEndpointTest.java | 2 +-
.../metrics/MicroProfileMetricsGaugeTest.java | 4 +-
.../metrics/MicroProfileMetricsHistogramTest.java | 4 +-
.../metrics/MicroProfileMetricsMetadataTest.java | 4 +-
.../metrics/MicroProfileMetricsMeterTest.java | 4 +-
.../metrics/MicroProfileMetricsTagTest.java | 4 +-
.../metrics/MicroProfileMetricsTimerTest.java | 4 +-
...rofileMetricsCamelContextEventNotifierTest.java | 4 +-
...croProfileMetricsExchangeEventNotifierTest.java | 4 +-
.../MicroProfileMetricsRouteEventNotifierTest.java | 6 +-
.../MiloClientCachingConnectionManagerTest.java | 4 +-
.../milo/MonitorItemMultiConnectionsCertTest.java | 4 +-
.../milo/MonitorItemMultiConnectionsTest.java | 4 +-
.../camel/component/milo/MonitorItemTest.java | 4 +-
.../camel/component/milo/ReadValuesClientTest.java | 4 +-
.../camel/component/milo/WriteClientTest.java | 4 +-
.../component/milo/browse/BrowseServerTest.java | 4 +-
.../camel/component/milo/call/CallClientTest.java | 6 +-
.../component/milo/server/ServerLocalTest.java | 8 +-
.../component/milo/testing/ExampleClient.java | 2 +-
.../component/milo/testing/ExampleServer.java | 2 +-
.../apache/camel/component/mina/BaseMinaTest.java | 2 +-
.../camel/component/mina/MessageIOSessionTest.java | 4 +-
.../MinaClientModeTcpTextlineDelimiterTest.java | 4 +-
.../camel/component/mina/MinaClientServerTest.java | 8 +-
.../camel/component/mina/MinaConsumerTest.java | 8 +-
.../camel/component/mina/MinaCustomCodecTest.java | 12 +-
.../mina/MinaDisconnectRaceConditionTest.java | 4 +-
.../camel/component/mina/MinaDisconnectTest.java | 8 +-
.../camel/component/mina/MinaEncodingTest.java | 2 +-
.../camel/component/mina/MinaFiltersTest.java | 6 +-
.../camel/component/mina/MinaInOnlyRouteTest.java | 4 +-
.../MinaInOutCloseSessionWhenCompleteTest.java | 6 +-
.../camel/component/mina/MinaInOutRouteTest.java | 4 +-
.../mina/MinaInOutRouteTextLineDelimiterTest.java | 4 +-
.../mina/MinaInOutWithForcedNoResponseTest.java | 6 +-
.../component/mina/MinaMaxLineLengthTest.java | 6 +-
.../component/mina/MinaNoDefaultCodecTest.java | 2 +-
.../mina/MinaNoResponseFromServerTest.java | 18 +-
.../mina/MinaProducerAnotherConcurrentTest.java | 8 +-
.../component/mina/MinaProducerConcurrentTest.java | 6 +-
.../camel/component/mina/MinaReverserServer.java | 2 +-
.../component/mina/MinaSendToProcessorTest.java | 4 +-
.../camel/component/mina/MinaTcpWithInOutTest.java | 4 +-
.../mina/MinaTransferExchangeOptionTest.java | 2 +-
.../camel/component/mina/MinaUdpNoCamelTest.java | 10 +-
.../component/mina/MinaUdpUsingTemplateTest.java | 2 +-
.../component/mina/MinaVMCustomCodecTest.java | 10 +-
.../integration/MinioCopyObjectOperationIT.java | 4 +-
.../integration/MinioListObjectsOperationIT.java | 3 +-
.../integration/MinioObjectRangeOperationIT.java | 2 +-
.../MllpTcpServerConsumerLenientBindTest.java | 2 +-
.../apache/camel/component/mllp/LogPhiTest.java | 4 +-
.../MllpAcknowledgementDeliveryExceptionTest.java | 12 +-
.../mllp/MllpAcknowledgementExceptionTest.java | 18 +-
.../MllpAcknowledgementReceiveExceptionTest.java | 24 +--
.../MllpAcknowledgementTimeoutExceptionTest.java | 27 +--
...plicationErrorAcknowledgementExceptionTest.java | 9 +-
...licationRejectAcknowledgementExceptionTest.java | 9 +-
...llpCommitErrorAcknowledgementExceptionTest.java | 9 +-
...lpCommitRejectAcknowledgementExceptionTest.java | 9 +-
.../camel/component/mllp/MllpExceptionTest.java | 16 +-
.../mllp/MllpIdleTimeoutStrategyTest.java | 4 +-
.../MllpInvalidAcknowledgementExceptionTest.java | 6 +-
.../mllp/MllpInvalidMessageExceptionTest.java | 6 +-
.../mllp/MllpMaxConcurrentConsumersTest.java | 2 +-
.../MllpNegativeAcknowledgementExceptionTest.java | 9 +-
.../MllpProducerConsumerLoopbackInOnlyTest.java | 2 +-
.../mllp/MllpProducerConsumerLoopbackTest.java | 4 +-
.../component/mllp/MllpReceiveExceptionTest.java | 18 +-
.../component/mllp/MllpSocketExceptionTest.java | 6 +-
.../MllpTcpClientProducerConnectionErrorTest.java | 2 +-
...TcpClientProducerIdleConnectionTimeoutTest.java | 2 +-
.../component/mllp/MllpTcpServerCharsetTest.java | 2 +-
.../mllp/MllpTcpServerConsumerBindTimeoutTest.java | 2 +-
.../MllpTcpServerConsumerMessageHeadersTest.java | 2 +-
...MllpTcpServerConsumerMulitpleTcpPacketTest.java | 2 +-
...umerOptionalEndOfDataWithoutValidationTest.java | 2 +-
.../mllp/MllpTcpServerConsumerTransactionTest.java | 4 +-
.../component/mllp/MllpWriteExceptionTest.java | 12 +-
...tProducerEndOfDataAndValidationTestSupport.java | 29 ++-
...cpServerConsumerAcknowledgementTestSupport.java | 2 +-
...rConsumerEndOfDataAndValidationTestSupport.java | 8 +-
.../camel/component/mllp/internal/Hl7UtilTest.java | 57 +++---
.../mllp/internal/MllpSocketBufferTest.java | 24 +--
.../mllp/internal/MllpSocketBufferWriteTest.java | 39 ++--
.../camel/test/executor/PooledExecutorTest.java | 4 +-
.../test/junit/rule/mllp/MllpClientResource.java | 10 +-
.../test/junit/rule/mllp/MllpServerResource.java | 2 +-
.../camel/test/mllp/PassthroughProcessor.java | 2 +-
.../camel/test/stub/tcp/SocketInputStreamStub.java | 6 +-
.../org/apache/camel/test/stub/tcp/SocketStub.java | 16 +-
.../apache/camel/component/mock/MockEndpoint.java | 31 +++-
.../gridfs/integration/GridFsConsumerIT.java | 4 +-
.../integration/GridFsProducerOperationsIT.java | 4 +-
.../camel/language/mvel/MvelComponentTest.java | 10 +-
.../apache/camel/language/mvel/MvelFilterTest.java | 4 +-
.../camel/language/mvel/MvelResourceTest.java | 4 +-
.../language/mvel/MvelScriptingLanguageTest.java | 2 +-
.../org/apache/camel/language/mvel/MvelTest.java | 6 +-
.../mybatis/MyBatisBatchConsumerTest.java | 4 +-
.../mybatis/MyBatisConsumerIdleMessageTest.java | 4 +-
.../component/mybatis/MyBatisDeleteListTest.java | 4 +-
.../camel/component/mybatis/MyBatisDeleteTest.java | 4 +-
.../component/mybatis/MyBatisExecutorTypeTest.java | 4 +-
.../component/mybatis/MyBatisInsertListTest.java | 4 +-
.../camel/component/mybatis/MyBatisInsertTest.java | 4 +-
.../MyBatisInsertWithInputAndOutputHeaderTest.java | 4 +-
.../mybatis/MyBatisInsertWithInputHeaderTest.java | 4 +-
.../mybatis/MyBatisInsertWithOutputHeaderTest.java | 4 +-
.../mybatis/MyBatisInsertWithRollbackTest.java | 4 +-
.../mybatis/MyBatisPollingDelayRouteTest.java | 4 +-
.../camel/component/mybatis/MyBatisQueueTest.java | 4 +-
.../mybatis/MyBatisRouteEmptyResultSetTest.java | 4 +-
.../component/mybatis/MyBatisSelectListTest.java | 4 +-
.../mybatis/MyBatisSelectListWithSplitTest.java | 4 +-
...SelectOneExchangeInOutWithOutputHeaderTest.java | 4 +-
.../component/mybatis/MyBatisSelectOneTest.java | 4 +-
...BatisSelectOneWithInputAndOutputHeaderTest.java | 4 +-
.../MyBatisSelectOneWithInputHeaderTest.java | 4 +-
.../MyBatisSelectOneWithOutputHeaderTest.java | 4 +-
.../mybatis/MyBatisShutdownAllTasksTest.java | 4 +-
.../MyBatisShutdownCurrentTaskOnlyTest.java | 4 +-
.../mybatis/MyBatisUnknownStatementTypeTest.java | 2 +-
.../component/mybatis/MyBatisUpdateListTest.java | 4 +-
.../camel/component/mybatis/MyBatisUpdateTest.java | 4 +-
.../mybatis/bean/MyBatisBeanInsertTest.java | 4 +-
.../mybatis/bean/MyBatisBeanSelectListTest.java | 4 +-
.../mybatis/bean/MyBatisBeanSelectOneTest.java | 4 +-
.../MyBatisBeanSelectOneWithInputHeaderTest.java | 4 +-
.../MyBatisBeanSelectOneWithOutputHeaderTest.java | 4 +-
.../nats/integration/NatsAuthConsumerLoadIT.java | 7 +-
.../nats/integration/NatsAuthProducerIT.java | 6 +-
.../integration/NatsAuthTokenConsumerLoadIT.java | 7 +-
.../nats/integration/NatsAuthTokenProducerIT.java | 6 +-
.../integration/NatsConsumerHeadersSupportIT.java | 4 +-
.../component/nats/integration/NatsConsumerIT.java | 4 +-
.../nats/integration/NatsConsumerLoadIT.java | 4 +-
.../integration/NatsConsumerMaxMessagesIT.java | 8 +-
.../NatsConsumerMaxMessagesQueueIT.java | 8 +-
.../nats/integration/NatsConsumerReplyToIT.java | 4 +-
.../NatsConsumerWithConnectionLoadIT.java | 4 +-
.../integration/NatsConsumerWithRedeliveryIT.java | 4 +-
.../component/nats/integration/NatsProducerIT.java | 6 +-
.../nats/integration/NatsProducerReplyToIT.java | 4 +-
.../integration/NatsProducerReplyToTimeoutIT.java | 4 +-
.../component/nitrite/NitriteComponentTest.java | 2 +-
.../nitrite/NitriteConsumerCollectionTest.java | 2 +-
.../nitrite/NitriteConsumerRepositoryTest.java | 2 +-
.../nitrite/NitriteProducerCollectionTest.java | 22 +--
.../nitrite/NitriteProducerRepositoryTest.java | 18 +-
.../camel/language/ognl/OgnlInvokeMethodTest.java | 4 +-
.../camel/language/ognl/OgnlResourceTest.java | 4 +-
.../language/ognl/OgnlScriptingLanguageTest.java | 2 +-
.../org/apache/camel/language/ognl/OgnlTest.java | 8 +-
.../olingo2/Olingo2AppAPIETagEnabledTest.java | 2 +-
.../olingo2/Olingo2ComponentProducerTest.java | 6 +-
.../camel/component/olingo2/Olingo2RouteTest.java | 4 +-
.../camel/component/olingo4/Olingo4AppAPITest.java | 8 +-
.../olingo4/AbstractOlingo4TestSupport.java | 3 +-
.../olingo4/Olingo4ComponentProducerTest.java | 14 +-
.../camel/component/olingo4/Olingo4RouteTest.java | 4 +-
.../org/apache/camel/openapi/ComplexTypesTest.java | 2 +-
.../camel/openapi/RestOpenApiLicenseInfoTest.java | 2 +-
...estOpenApiModelApiSecurityRequirementsTest.java | 2 +-
.../camel/openapi/RestOpenApiProcessorTest.java | 12 +-
.../RestOpenApiReaderApiDocsOverrideTest.java | 4 +-
.../openapi/RestOpenApiReaderApiDocsTest.java | 4 +-
.../openapi/RestOpenApiReaderContextPathTest.java | 4 +-
.../openapi/RestOpenApiReaderDayOfWeekTest.java | 4 +-
...RestOpenApiReaderEnableVendorExtensionTest.java | 4 +-
.../RestOpenApiReaderFileResponseModelTest.java | 4 +-
.../RestOpenApiReaderModelApiSecurityTest.java | 4 +-
.../RestOpenApiReaderModelBookOrderTest.java | 4 +-
.../camel/openapi/RestOpenApiReaderModelTest.java | 4 +-
.../RestOpenApiReaderPropertyPlaceholderTest.java | 4 +-
.../camel/openapi/RestOpenApiReaderTest.java | 4 +-
.../openapi/RestOpenApiV2SecuritySchemesTest.java | 2 +-
.../openapi/RestOpenApiV3SecuritySchemesTest.java | 4 +-
.../openapi/producer/DummyRestProducerFactory.java | 5 +-
.../camel/openapi/producer/RestOpenApiGetTest.java | 4 +-
.../producer/RestOpenApiGetUriParamTest.java | 4 +-
.../openstack/AbstractProducerTestSupport.java | 4 +-
.../apache/camel/opentelemetry/ABCRouteTest.java | 6 +-
.../ClientRecipientListRouteTest.java | 6 +-
.../CustomComponentNameRouteTest.java | 6 +-
.../opentelemetry/MulticastParallelRouteTest.java | 6 +-
.../camel/opentelemetry/MulticastRouteTest.java | 6 +-
.../camel/opentelemetry/RouteConcurrentTest.java | 8 +-
.../camel/opentelemetry/SpanProcessorsTest.java | 6 +-
.../apache/camel/opentelemetry/TwoServiceTest.java | 6 +-
.../opentelemetry/TwoServiceWithExcludeTest.java | 6 +-
.../org/apache/camel/opentracing/ABCRouteTest.java | 6 +-
.../opentracing/CamelOpenTracingTestSupport.java | 2 +-
.../opentracing/ClientRecipientListRouteTest.java | 6 +-
.../opentracing/CustomComponentNameRouteTest.java | 6 +-
.../opentracing/EIPTracingActiveSpanTest.java | 8 +-
.../camel/opentracing/EIPTracingRouteTest.java | 6 +-
.../apache/camel/opentracing/MDCSupportTest.java | 8 +-
.../opentracing/MulticastParallelRouteTest.java | 6 +-
.../camel/opentracing/MulticastRouteTest.java | 6 +-
.../OpentracingSpanCollectorInRegistryTest.java | 2 +-
.../camel/opentracing/RouteConcurrentTest.java | 8 +-
.../camel/opentracing/SpanProcessorsTest.java | 6 +-
.../SpringOpenTracingSimpleRouteTest.java | 2 +-
.../TracingClientRecipientListRouteTest.java | 6 +-
.../TracingMulticastParallelRouteTest.java | 6 +-
.../apache/camel/opentracing/TwoServiceTest.java | 6 +-
.../opentracing/TwoServiceWithExcludeTest.java | 6 +-
.../opentracing/integration/InterprocessIT.java | 6 +-
.../optaplanner/OptaPlannerConsumerTest.java | 2 +-
.../optaplanner/OptaPlannerSyncSolverTest.java | 2 +-
.../optaplanner/OptaplannerSolverManagerTest.java | 2 +-
.../apache/camel/component/pdf/PdfAppendTest.java | 4 +-
.../camel/component/pdf/PdfCreationTest.java | 4 +-
.../camel/component/pdf/PdfTextExtractionTest.java | 4 +-
.../pdf/text/PatternSplitStrategyTest.java | 2 +-
.../component/pdf/text/WordSplitStrategyTest.java | 2 +-
.../apache/camel/pgevent/PgEventHelperTest.java | 2 +-
.../camel/pgevent/integration/PgEventPubSubIT.java | 4 +-
.../PgEventWithDefinedDatasourceIT.java | 6 +-
.../camel/component/printer/PrinterPrintTest.java | 10 +-
.../ProtobufMarshalAndUnmarshalJsonTest.java | 4 +-
.../ProtobufMarshalAndUnmarshalMapTest.java | 4 +-
.../ProtobufMarshalAndUnmarshalSpringTest.java | 4 +-
.../protobuf/ProtobufMarshalAndUnmarshalTest.java | 8 +-
.../component/pubnub/PubNubConfigurationTest.java | 2 +-
.../camel/component/pubnub/PubNubFireTest.java | 2 +-
.../component/pubnub/PubNubOperationsTest.java | 10 +-
.../camel/component/pubnub/PubNubPresenceTest.java | 2 +-
.../camel/component/pubnub/PubNubPublishTest.java | 4 +-
.../component/pubnub/PubNubSubscriberTest.java | 2 +-
.../camel/component/pubnub/PubNubTestBase.java | 4 +-
.../pubnub/example/PubNubGeoLocationExample.java | 2 +-
.../pubnub/example/PubNubPresenseExample.java | 2 +-
.../pubnub/example/PubNubSensor2Example.java | 4 +-
.../pubnub/example/PubNubSensorExample.java | 2 +-
.../pubnub/example/PubNubStateExample.java | 2 +-
.../quartz/DelegateEndpointQuartzTest.java | 2 +-
.../quartz/QuartzAddDynamicRouteTest.java | 2 +-
...uartzAddRoutesAfterCamelContextStartedTest.java | 2 +-
.../component/quartz/QuartzAutoStartTest.java | 4 +-
...omponentCamelContextSchedulerIsolationTest.java | 3 +-
...tzComponentCamelContextSharedSchedulerTest.java | 6 +-
.../component/quartz/QuartzComponentTest.java | 2 +-
.../quartz/QuartzCronRouteFireNowTest.java | 3 +-
.../quartz/QuartzCronRouteWithSmallCacheTest.java | 2 +-
.../quartz/QuartzCustomCalendarFireTest.java | 2 +-
.../quartz/QuartzCustomCalendarNoFireTest.java | 2 +-
.../quartz/QuartzEndpointConfigureTest.java | 4 +-
.../component/quartz/QuartzManagementTest.java | 4 +-
.../component/quartz/QuartzNameCollisionTest.java | 18 +-
.../quartz/QuartzOneCamelContextRestartTest.java | 4 +-
.../QuartzOneCamelContextSuspendResumeTest.java | 4 +-
.../component/quartz/QuartzPropertiesTest.java | 2 +-
.../quartz/QuartzTriggerParametersTest.java | 4 +-
.../quartz/QuartzTwoCamelContextRestartTest.java | 6 +-
.../QuartzTwoCamelContextSameNameClashTest.java | 6 +-
.../QuartzTwoCamelContextSuspendResumeTest.java | 6 +-
.../quartz/QuartzTwoCamelContextTest.java | 8 +-
...QuartzConsumerTwoAppsClusteredRecoveryTest.java | 2 +-
.../component/quartz/StatefulQuartzRouteTest.java | 2 +-
.../quartz/cron/QuartzCronMappingTest.java | 4 +-
.../FileConsumerQuartzSchedulerRestartTest.java | 4 +-
.../quartz/FileConsumerQuartzSchedulerTest.java | 4 +-
.../quartz/MultiplePoliciesOnRouteTest.java | 2 +-
.../RouteAutoStopFalseCronScheduledPolicyTest.java | 2 +-
.../quickfixj/QuickfixjComponentTest.java | 11 +-
.../component/quickfixj/QuickfixjEngineTest.java | 4 +-
.../quickfixj/examples/AuthenticationExample.java | 2 +-
.../quickfixj/examples/RestartRouteExample.java | 2 +-
.../quickfixj/examples/trading/TradeExecutor.java | 19 +-
.../examples/trading/TradeExecutorComponent.java | 10 +-
.../transform/QuickfixjEventJsonTransformer.java | 3 +-
.../transform/QuickfixjMessageJsonTransformer.java | 4 +-
.../component/rabbitmq/RabbitMQEndpointTest.java | 38 ++--
.../RabbitMQLookupConnectionFactoryTest.java | 4 +-
.../component/rabbitmq/RabbitMQProducerTest.java | 32 ++--
.../rabbitmq/integration/RabbitMQBasicIT.java | 4 +-
.../rabbitmq/integration/RabbitMQConsumerIT.java | 4 +-
.../integration/RabbitMQConsumerReplyToIT.java | 12 +-
.../RabbitMQDeadLetterRoutingKeyIT.java | 2 +-
.../rabbitmq/integration/RabbitMQInOutIT.java | 15 +-
.../rabbitmq/integration/RabbitMQLoadIT.java | 4 +-
.../rabbitmq/integration/RabbitMQProducerIT.java | 26 ++-
.../integration/RabbitMQReConnectionIT.java | 4 +-
.../RabbitMQRequeueHandledExceptionIT.java | 4 +-
.../RabbitMQRequeueUnhandledExceptionIT.java | 4 +-
.../integration/RabbitMQSupendResumeIT.java | 4 +-
.../rabbitmq/integration/RabbitMQToDIT.java | 4 +-
.../integration/RabbitMQToDSendDynamicIT.java | 6 +-
.../integration/qpid/RabbitMQProducerQpidIT.java | 9 +-
.../integration/qpid/RabbitMQRequeueQpidIT.java | 6 +-
.../camel/reactive/SimpleMockLookupVertxTest.java | 4 +-
.../org/apache/camel/reactive/SimpleMockTest.java | 4 +-
.../reactive/streams/BasicSubscriberTest.java | 4 +-
.../reactive/streams/CamelReactiveStreamsTest.java | 8 +-
.../reactive/streams/ConcurrentConsumersTest.java | 2 +-
.../reactive/streams/DelayedMonoPublisherTest.java | 8 +-
.../reactive/streams/ExchangeRequestTest.java | 8 +-
.../streams/PublisherTypeConversionTest.java | 2 +-
.../reactive/streams/ReactiveStreamsJMXTest.java | 2 +-
.../reactive/streams/RequestRefillTest.java | 2 +-
.../ReactorStreamsServiceBackpressureTest.java | 6 +-
.../engine/ReactorStreamsServiceEventTypeTest.java | 10 +-
.../ReactorStreamsServiceSubscriberTest.java | 6 +-
.../reactor/engine/ReactorStreamsServiceTest.java | 14 +-
.../engine/ReactorStreamsServiceTestSupport.java | 2 +-
.../ResilienceExistingCircuitBreakerTest.java | 4 +-
.../ResilienceInheritErrorHandlerTest.java | 4 +-
.../resilience4j/ResilienceManagementTest.java | 4 +-
.../ResilienceRouteBulkheadFallbackTest.java | 4 +-
.../ResilienceRouteBulkheadOkTest.java | 4 +-
.../resilience4j/ResilienceRouteFallbackTest.java | 4 +-
.../ResilienceRouteFallbackViaNetworkTest.java | 4 +-
.../resilience4j/ResilienceRouteOkTest.java | 4 +-
.../resilience4j/ResilienceRouteRejectedTest.java | 4 +-
.../resilience4j/ResilienceTimeoutTest.java | 10 +-
.../ResilienceTimeoutThreadPoolTest.java | 10 +-
.../ResilienceTimeoutWithFallbackTest.java | 8 +-
.../camel/github/GitHubResourceResolverTest.java | 2 +-
.../camel/component/rest/openapi/HttpsTest.java | 4 +-
.../camel/component/rest/openapi/HttpsV3Test.java | 4 +-
.../rest/openapi/RestOpenApiComponentTest.java | 4 +-
.../rest/openapi/RestOpenApiComponentV3Test.java | 4 +-
.../rest/openapi/RestOpenApiEndpointTest.java | 13 +-
.../rest/openapi/RestOpenApiEndpointV3Test.java | 13 +-
.../camel/component/rest/swagger/HttpsTest.java | 4 +-
.../rest/swagger/RestSwaggerComponentTest.java | 4 +-
.../rest/swagger/RestSwaggerEndpointTest.java | 12 +-
.../test/ResteasyConsumerMatchUriOnPrefix.java | 5 +-
.../resteasy/test/ResteasyConsumerProxyTest.java | 8 +-
.../resteasy/test/ResteasyConsumerTest.java | 2 +-
.../test/ResteasyConsumerTwoServletsTest.java | 2 +-
.../resteasy/test/ResteasyMethodRestrictTest.java | 2 +-
.../resteasy/test/ResteasyProducerProxyTest.java | 26 +--
.../resteasy/test/ResteasyProducerTest.java | 24 +--
.../test/ResteasyRestDSLProxyCamelTest.java | 2 +-
.../resteasy/test/ResteasyRestDSLProxyTest.java | 2 +-
.../resteasy/test/ResteasyRestDSLTest.java | 2 +-
.../resteasy/test/ResteasySimpleConsumerTest.java | 4 +-
.../resteasy/test/ServletInitializerTest.java | 5 +-
.../camel/component/resteasy/test/WebTest.java | 4 +-
.../resteasy/test/beans/CustomerService.java | 20 +-
.../component/resteasy/test/beans/ProxyBean.java | 2 +-
.../resteasy/test/beans/ServletOneService.java | 5 +-
.../resteasy/test/beans/ServletTwoService.java | 5 +-
.../resteasy/test/beans/SimpleService.java | 11 +-
.../component/resteasy/test/beans/TestBean.java | 2 +-
.../RobotFrameworkCamelUtilsTest.java | 2 +-
.../RobotFrameworkComponentTest.java | 2 +-
.../camel/component/rss/JettyTestServer.java | 3 +-
.../camel/component/rss/RssEndpointTest.java | 2 +-
.../component/rss/RssEntryPollingConsumerTest.java | 4 +-
.../RssEntryPollingConsumerWithBasicAuthTest.java | 4 +-
.../rss/RssEntryPollingConsumerWithFilterTest.java | 6 +-
.../component/rss/RssEntrySortDefaultsTest.java | 4 +-
.../camel/component/rss/RssEntrySortTest.java | 6 +-
.../apache/camel/component/rss/RssFilterTest.java | 6 +-
.../rss/RssHttpNoCamelParametersTest.java | 4 +-
.../rss/RssMultipleEndpointsIssueTest.java | 4 +-
.../component/rss/RssPollingConsumerTest.java | 4 +-
.../rss/RssPollingConsumerWithBasicAuthTest.java | 4 +-
...sPollingConsumerWithFeedHeaderDisabledTest.java | 4 +-
.../camel/dataformat/rss/RssConverterTest.java | 4 +-
.../camel/dataformat/rss/RssDataFormatTest.java | 4 +-
.../dataformat/rss/RssFilterWithXPathTest.java | 4 +-
.../RxJavaStreamsServiceBackpressureTest.java | 6 +-
.../engine/RxJavaStreamsServiceEventTypeTest.java | 10 +-
.../engine/RxJavaStreamsServiceSubscriberTest.java | 6 +-
.../rxjava/engine/RxJavaStreamsServiceTest.java | 14 +-
.../engine/RxJavaStreamsServiceTestSupport.java | 2 +-
.../sap/netweaver/NetWeaverFlightDataTest.java | 4 +-
.../netweaver/NetWeaverFlightDataVelocityTest.java | 4 +-
.../builder/saxon/BeanWithXQueryInjectionTest.java | 4 +-
.../camel/builder/saxon/ParameterDynamicTest.java | 4 +-
.../camel/builder/saxon/SaxonXPathSplitTest.java | 4 +-
.../apache/camel/builder/saxon/SaxonXPathTest.java | 4 +-
.../saxon/XPathSplitChoicePerformanceTest.java | 16 +-
.../org/apache/camel/builder/saxon/XPathTest.java | 8 +-
...XQueryHeaderNameResultTypeAndNamespaceTest.java | 4 +-
.../camel/builder/saxon/XQueryHeaderNameTest.java | 4 +-
.../camel/builder/saxon/XQueryResourceTest.java | 4 +-
.../org/apache/camel/builder/saxon/XQueryTest.java | 2 +-
.../builder/saxon/XQueryTransformIssueTest.java | 4 +-
...eanWithXQueryInjectionUsingHeaderValueTest.java | 4 +-
.../component/xquery/SoapPayloadBeanTest.java | 4 +-
.../xquery/XQueryComponentConfigurationTest.java | 2 +-
.../component/xquery/XQueryConcurrencyTest.java | 4 +-
.../xquery/XQueryEndpointConfigurationTest.java | 2 +-
.../xquery/XQueryFromFileExceptionTest.java | 4 +-
.../camel/component/xquery/XQueryFromFileTest.java | 4 +-
.../xquery/XQueryLanguageFromFileTest.java | 4 +-
.../xquery/XQueryPropogateHeadersTest.java | 4 +-
.../xquery/XQueryStripWhitespaceTest.java | 4 +-
.../xquery/XQueryURLBasedConcurrencyTest.java | 4 +-
.../component/xquery/XQueryWithExtensionTest.java | 6 +-
.../SaxonLanguageExtensionFunctionsTest.java | 4 +-
.../camel/converter/saxon/SaxonConverterTest.java | 19 +-
.../xpath/XPathHeaderEnableSaxonJavaDslTest.java | 4 +-
.../schematron/SchematronComponentTest.java | 2 +-
.../schematron/processor/TemplatesFactoryTest.java | 2 +-
.../servicenow/ServiceNowAttachmentIT.java | 2 +-
.../camel/component/servicenow/ServiceNowIT.java | 4 +-
.../component/servicenow/ServiceNowITSupport.java | 2 +-
.../servicenow/ServiceNowImportSetIT.java | 2 +-
.../servicenow/ServiceNowMetaDataExtensionIT.java | 2 +-
.../servicenow/ServiceNowScorecardIT.java | 4 +-
.../servicenow/ServiceNowServiceCatalogIT.java | 6 +-
.../component/servicenow/ServiceNowTableIT.java | 2 +-
.../security/ShiroAuthenticationBase64Test.java | 2 +-
...nticationReauthenticateFalseAndNewUserTest.java | 4 +-
.../shiro/security/ShiroAuthenticationTest.java | 6 +-
.../shiro/security/ShiroAuthorizationTest.java | 4 +-
.../security/ShiroRolesAuthorizationTest.java | 4 +-
.../apache/camel/component/sjms/SjmsEndpoint.java | 1 +
.../apache/camel/component/sjms/SjmsTemplate.java | 40 +++-
.../slack/SlackComponentVerifierExtensionTest.java | 12 +-
.../camel/component/slack/SlackConsumerTest.java | 4 +-
.../component/smpp/AbstractSmppCommandTest.java | 2 +-
.../camel/component/smpp/SmppBindingTest.java | 4 +-
.../camel/component/smpp/SmppComponentTest.java | 4 +-
.../smpp/integration/SmppComponentManualIT.java | 14 +-
.../integration/SmppComponentSpringManualIT.java | 10 +-
.../integration/SmppConsumerReconnectManualIT.java | 4 +-
.../integration/SmppProducerReconnectManualIT.java | 4 +-
.../apache/camel/component/snmp/PollOIDTest.java | 2 +-
.../apache/camel/component/snmp/ProducerTest.java | 2 +-
.../org/apache/camel/component/snmp/TrapTest.java | 2 +-
.../camel/component/snmp/UriConfigurationTest.java | 6 +-
.../apache/camel/component/snmp/WalkOIDTest.java | 2 +-
.../splunkhec/integration/SplunkHECIT.java | 2 +-
.../component/splunk/ConsumerStreamingTest.java | 2 +-
.../camel/component/splunk/ConsumerTest.java | 2 +-
.../camel/component/splunk/ProducerTest.java | 4 +-
.../camel/component/splunk/RawProducerTest.java | 2 +-
.../splunk/SplunkComponentConfigurationTest.java | 2 +-
.../splunk/integration/NormalSearchTest.java | 2 +-
.../splunk/integration/RealtimeSearchTest.java | 2 +-
.../splunk/integration/SavedSearchTest.java | 2 +-
.../splunk/integration/SplunkProducerTest.java | 2 +-
.../component/splunk/integration/SplunkTest.java | 2 +-
.../camel/component/stitch/StitchProducerTest.java | 9 +-
.../stitch/integration/StitchProducerIT.java | 4 +-
.../operations/StitchProducerOperationsTest.java | 5 +-
.../camel/component/stream/StreamDelayTest.java | 2 +-
.../camel/component/stream/StreamEncodingTest.java | 2 +-
.../camel/component/stream/StreamFileTest.java | 4 +-
.../stream/StreamGroupLinesLastStrategyTest.java | 4 +-
.../stream/StreamGroupLinesStrategyTest.java | 4 +-
.../component/stream/StreamGroupLinesTest.java | 4 +-
.../camel/component/stream/StreamHeaderTest.java | 3 +-
.../component/stream/StreamSystemErrTest.java | 2 +-
.../stream/StreamSystemOutNewLineOffTest.java | 2 +-
.../component/stream/StreamSystemOutTest.java | 2 +-
.../camel/component/stream/mock/Handler.java | 3 +-
.../component/stream/mock/MockURLConnection.java | 5 +-
.../StringTemplateConcurrentTest.java | 2 +-
.../StringTemplateContentCacheTest.java | 4 +-
.../StringTemplateCustomDelimiterTest.java | 4 +-
.../stringtemplate/StringTemplateLetterTest.java | 4 +-
.../stringtemplate/StringTemplateTest.java | 4 +-
.../StringTemplateViaHeaderTest.java | 4 +-
.../vertx/http/VertxHttpAuthenticationTest.java | 4 +-
.../vertx/http/VertxHttpCustomBindingTest.java | 12 +-
.../http/VertxHttpCustomHeaderFilterTest.java | 4 +-
.../component/vertx/http/VertxHttpGzipTest.java | 8 +-
.../component/vertx/http/VertxHttpMethodTest.java | 4 +-
.../vertx/http/VertxHttpProducerLoadTest.java | 4 +-
.../vertx/http/VertxHttpProducerTest.java | 8 +-
.../vertx/http/VertxHttpProducerToDTest.java | 4 +-
.../vertx/http/VertxHttpProxyServerTest.java | 4 +-
.../vertx/http/VertxHttpQueryStringTest.java | 4 +-
.../http/VertxHttpRequestWithPayloadTest.java | 6 +-
.../http/VertxHttpSSLGlobalConfigurationTest.java | 8 +-
.../component/vertx/http/VertxHttpSSLTest.java | 8 +-
.../vertx/http/VertxHttpSendDynamicAwareTest.java | 6 +-
.../vertx/http/VertxHttpSerializedBodyTest.java | 4 +-
.../component/vertx/http/VertxHttpSessionTest.java | 8 +-
.../vertx/http/VertxHttpStreamingResponseTest.java | 2 +-
.../http/VertxHttpThrowExceptionOnFailureTest.java | 6 +-
.../component/vertx/http/VertxHttpTimeoutTest.java | 4 +-
.../vertx/http/VertxHttpTransferExceptionTest.java | 4 +-
.../component/vertx/http/VertxHttpUriTest.java | 4 +-
.../vertx/kafka/VertxKafkaComponentTest.java | 4 +-
.../kafka/VertxKafkaConsumerBatchSizeTest.java | 4 +-
.../vertx/kafka/VertxKafkaConsumerFullTest.java | 9 +-
.../kafka/VertxKafkaConsumerManualCommitTest.java | 4 +-
.../kafka/VertxKafkaConsumerSuspendResumeTest.java | 4 +-
.../vertx/kafka/VertxKafkaProducerFullTest.java | 13 +-
.../component/vertx/kafka/VertxKafkaToDTest.java | 6 +-
.../VertxWebsocketEndpointConfigurationTest.java | 4 +-
.../VertxWebsocketExternalServerTest.java | 4 +-
.../websocket/VertxWebsocketMultiConsumerTest.java | 4 +-
.../vertx/websocket/VertxWebsocketOriginTest.java | 4 +-
.../vertx/websocket/VertxWebsocketRouterTest.java | 10 +-
.../vertx/websocket/VertxWebsocketSSLTest.java | 6 +-
.../vertx/websocket/VertxWebsocketTest.java | 6 +-
.../component/vertx/VertxBaseTestSupport.java | 2 +-
.../component/vertx/VertxMultipleConsumerTest.java | 4 +-
.../component/vertx/VertxRequestReplyTest.java | 4 +-
.../component/vertx/VertxRoutePubSubTest.java | 4 +-
.../camel/component/vertx/VertxRouteTest.java | 4 +-
.../java/org/apache/camel/ConsumerListener.java | 52 ++++++
.../org/apache/camel/ConsumerListenerAware.java | 27 +--
.../src/main/java/org/apache/camel/Route.java | 5 +
.../org/apache/camel/impl/engine/DefaultRoute.java | 12 ++
.../docs/modules/eips/examples/json/pausable.json | 1 +
.../docs/modules/eips/pages/resume-strategies.adoc | 28 ++-
.../services/org/apache/camel/model.properties | 1 +
.../resources/org/apache/camel/model/jaxb.index | 1 +
.../resources/org/apache/camel/model/pausable.json | 20 ++
.../org/apache/camel/model/PausableDefinition.java | 115 ++++++++++++
.../apache/camel/model/ProcessorDefinition.java | 58 ++++++
.../apache/camel/processor/PausableProcessor.java | 99 ++++++++++
.../org/apache/camel/reifier/PausableReifier.java | 71 +++++++
.../org/apache/camel/reifier/ProcessorReifier.java | 3 +
.../java/org/apache/camel/xml/in/ModelParser.java | 11 ++
.../components/modules/ROOT/examples/js/camel.js | 38 ++--
docs/gulpfile.js | 2 +-
.../dsl/KafkaComponentBuilderFactory.java | 13 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 27 ++-
.../dsl/yaml/deserializers/ModelDeserializers.java | 60 ++++++
.../deserializers/ModelDeserializersResolver.java | 2 +
.../src/generated/resources/camel-yaml-dsl.json | 24 +++
.../src/generated/resources/camelYamlDsl.json | 24 +++
parent/pom.xml | 4 +-
940 files changed, 3768 insertions(+), 2750 deletions(-)
create mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/pausable.json
copy components/{camel-stream/src/test/java/org/apache/camel/component/stream/mock/Handler.java => camel-kafka/src/main/java/org/apache/camel/component/kafka/SeekPolicy.java} (67%)
create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/KafkaConsumerListener.java
create mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/pause/KafkaPausableConsumerIT.java
create mode 100644 core/camel-api/src/main/java/org/apache/camel/ConsumerListener.java
copy components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/Handler.java => core/camel-api/src/main/java/org/apache/camel/ConsumerListenerAware.java (58%)
create mode 120000 core/camel-core-engine/src/main/docs/modules/eips/examples/json/pausable.json
create mode 100644 core/camel-core-model/src/generated/resources/org/apache/camel/model/pausable.json
create mode 100644 core/camel-core-model/src/main/java/org/apache/camel/model/PausableDefinition.java
create mode 100644 core/camel-core-processor/src/main/java/org/apache/camel/processor/PausableProcessor.java
create mode 100644 core/camel-core-reifier/src/main/java/org/apache/camel/reifier/PausableReifier.java
copy components/camel-nats/src/test/java/org/apache/camel/component/nats/integration/NatsAuthTokenProducerIT.java => docs/components/modules/ROOT/examples/js/camel.js (52%)