This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2f3aaf3562d470e45feed4311bb54db20414f7b0 Author: Claus Ibsen <[email protected]> AuthorDate: Sat Jan 23 11:02:16 2021 +0100 CAMEL-16020: camel-pulsar - Remove synchronous option. --- .../camel/catalog/docs/pulsar-component.adoc | 3 +- .../component/pulsar/PulsarEndpointConfigurer.java | 3 - .../component/pulsar/PulsarEndpointUriFactory.java | 3 +- .../org/apache/camel/component/pulsar/pulsar.json | 3 +- .../src/main/docs/pulsar-component.adoc | 3 +- .../camel/component/pulsar/PulsarEndpoint.java | 11 -- .../component/pulsar/PulsarMessageListener.java | 12 +- .../pulsar/PulsarConsumerInAsynchronousTest.java | 8 +- .../pulsar/PulsarConsumerInSynchronousTest.java | 217 --------------------- .../endpoint/dsl/PulsarEndpointBuilderFactory.java | 97 --------- .../modules/ROOT/pages/pulsar-component.adoc | 3 +- 11 files changed, 9 insertions(+), 354 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pulsar-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pulsar-component.adoc index 5f5e433..e956ee8 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pulsar-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pulsar-component.adoc @@ -108,7 +108,7 @@ with the following path and query parameters: |=== -=== Query Parameters (34 parameters): +=== Query Parameters (33 parameters): [width="100%",cols="2,5,^1,2",options="header"] @@ -147,7 +147,6 @@ with the following path and query parameters: | *messageRoutingMode* (producer) | Message Routing Mode to use. There are 3 enums and the value can be one of: SinglePartition, RoundRobinPartition, CustomPartition | RoundRobinPartition | MessageRoutingMode | *producerName* (producer) | Name of the producer. If unset, lets Pulsar select a unique identifier. | | String | *sendTimeoutMs* (producer) | Send timeout in milliseconds | 30000 | int -| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used | false | boolean |=== // endpoint options: END diff --git a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java index 67874e3..8855cbc 100644 --- a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java +++ b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java @@ -85,7 +85,6 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen case "subscriptionTopicsMode": target.getPulsarConfiguration().setSubscriptionTopicsMode(property(camelContext, org.apache.pulsar.client.api.RegexSubscriptionMode.class, value)); return true; case "subscriptiontype": case "subscriptionType": target.getPulsarConfiguration().setSubscriptionType(property(camelContext, org.apache.camel.component.pulsar.utils.consumers.SubscriptionType.class, value)); return true; - case "synchronous": target.setSynchronous(property(camelContext, boolean.class, value)); return true; case "topicspattern": case "topicsPattern": target.getPulsarConfiguration().setTopicsPattern(property(camelContext, boolean.class, value)); return true; default: return false; @@ -159,7 +158,6 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen case "subscriptionTopicsMode": return org.apache.pulsar.client.api.RegexSubscriptionMode.class; case "subscriptiontype": case "subscriptionType": return org.apache.camel.component.pulsar.utils.consumers.SubscriptionType.class; - case "synchronous": return boolean.class; case "topicspattern": case "topicsPattern": return boolean.class; default: return null; @@ -234,7 +232,6 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen case "subscriptionTopicsMode": return target.getPulsarConfiguration().getSubscriptionTopicsMode(); case "subscriptiontype": case "subscriptionType": return target.getPulsarConfiguration().getSubscriptionType(); - case "synchronous": return target.isSynchronous(); case "topicspattern": case "topicsPattern": return target.getPulsarConfiguration().isTopicsPattern(); default: return null; diff --git a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java index a71c126..611ad02 100644 --- a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java +++ b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java @@ -20,10 +20,9 @@ public class PulsarEndpointUriFactory extends org.apache.camel.support.component private static final Set<String> PROPERTY_NAMES; private static final Set<String> SECRET_PROPERTY_NAMES; static { - Set<String> props = new HashSet<>(38); + Set<String> props = new HashSet<>(37); props.add("initialSequenceId"); props.add("maxRedeliverCount"); - props.add("synchronous"); props.add("messageRouter"); props.add("batchingMaxMessages"); props.add("compressionType"); diff --git a/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json b/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json index 48d9691..ed1f7f6 100644 --- a/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json +++ b/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json @@ -96,7 +96,6 @@ "messageRouter": { "kind": "parameter", "displayName": "Message Router", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.pulsar.client.api.MessageRouter", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Custom Message Router to use" }, "messageRoutingMode": { "kind": "parameter", "displayName": "Message Routing Mode", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition", "RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "RoundRobinPartition", "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configuratio [...] "producerName": { "kind": "parameter", "displayName": "Producer Name", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Name of the producer. If unset, lets Pulsar select a unique identifier." }, - "sendTimeoutMs": { "kind": "parameter", "displayName": "Send Timeout Ms", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 30000, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Send timeout in milliseconds" }, - "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether synchronous processing should be strictly used" } + "sendTimeoutMs": { "kind": "parameter", "displayName": "Send Timeout Ms", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 30000, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Send timeout in milliseconds" } } } diff --git a/components/camel-pulsar/src/main/docs/pulsar-component.adoc b/components/camel-pulsar/src/main/docs/pulsar-component.adoc index 5f5e433..e956ee8 100644 --- a/components/camel-pulsar/src/main/docs/pulsar-component.adoc +++ b/components/camel-pulsar/src/main/docs/pulsar-component.adoc @@ -108,7 +108,7 @@ with the following path and query parameters: |=== -=== Query Parameters (34 parameters): +=== Query Parameters (33 parameters): [width="100%",cols="2,5,^1,2",options="header"] @@ -147,7 +147,6 @@ with the following path and query parameters: | *messageRoutingMode* (producer) | Message Routing Mode to use. There are 3 enums and the value can be one of: SinglePartition, RoundRobinPartition, CustomPartition | RoundRobinPartition | MessageRoutingMode | *producerName* (producer) | Name of the producer. If unset, lets Pulsar select a unique identifier. | | String | *sendTimeoutMs* (producer) | Send timeout in milliseconds | 30000 | int -| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used | false | boolean |=== // endpoint options: END diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java index 8af7183..d89088e 100644 --- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java +++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java @@ -50,9 +50,6 @@ public class PulsarEndpoint extends DefaultEndpoint { @UriPath @Metadata(required = true) private String topic; - @UriParam(defaultValue = "false", label = "advanced", - description = "Sets whether synchronous processing should be strictly used") - private boolean synchronous; @UriParam private PulsarConfiguration pulsarConfiguration; @@ -128,14 +125,6 @@ public class PulsarEndpoint extends DefaultEndpoint { this.topic = topic; } - public boolean isSynchronous() { - return synchronous; - } - - public void setSynchronous(boolean synchronous) { - this.synchronous = synchronous; - } - public PulsarConfiguration getPulsarConfiguration() { return pulsarConfiguration; } diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarMessageListener.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarMessageListener.java index f17b13d..0607bda 100644 --- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarMessageListener.java +++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarMessageListener.java @@ -49,22 +49,12 @@ public class PulsarMessageListener implements MessageListener<byte[]> { endpoint.getComponent().getPulsarMessageReceiptFactory() .newInstance(exchange, message, consumer)); } - if (endpoint.isSynchronous()) { - process(exchange, consumer, message); - } else { - processAsync(exchange, consumer, message); - } + processAsync(exchange, consumer, message); } catch (Exception exception) { handleProcessorException(exchange, exception); } } - private void process(final Exchange exchange, final Consumer<byte[]> consumer, final Message<byte[]> message) - throws Exception { - pulsarConsumer.getProcessor().process(exchange); - acknowledge(consumer, message); - } - private void processAsync(final Exchange exchange, final Consumer<byte[]> consumer, final Message<byte[]> message) { pulsarConsumer.getAsyncProcessor().process(exchange, new AsyncCallback() { @Override diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java index 649fd34..7eb5886 100644 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java +++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInAsynchronousTest.java @@ -55,18 +55,16 @@ public class PulsarConsumerInAsynchronousTest extends PulsarTestSupport { private static final String PRODUCER = "camel-producer-1"; @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_FALSE + "?numberOfConsumers=1&subscriptionType=Exclusive" - + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer" - + "&synchronous=false") + + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer") private Endpoint synchronousFalse; @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_FALSE_THROWS_EXCEPTION + "?numberOfConsumers=1&subscriptionType=Exclusive" - + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer" - + "&synchronous=false") + + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer") private Endpoint synchronousFalseThrowsException; @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_FALSE_MANUAL_ACK + "?numberOfConsumers=1&subscriptionType=Exclusive" + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer" - + "&synchronous=false" + "&allowManualAcknowledgement=true" + "&ackTimeoutMillis=1000") + + "&allowManualAcknowledgement=true" + "&ackTimeoutMillis=1000") private Endpoint synchronousFalseManualAck; @EndpointInject("mock:result") diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInSynchronousTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInSynchronousTest.java deleted file mode 100644 index f5ecf68..0000000 --- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInSynchronousTest.java +++ /dev/null @@ -1,217 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.pulsar; - -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.TimeUnit; - -import org.apache.camel.Endpoint; -import org.apache.camel.EndpointInject; -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.component.pulsar.utils.AutoConfiguration; -import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders; -import org.apache.camel.spi.Registry; -import org.apache.camel.support.SimpleRegistry; -import org.apache.pulsar.client.api.Producer; -import org.apache.pulsar.client.api.PulsarClient; -import org.apache.pulsar.client.api.PulsarClientException; -import org.apache.pulsar.client.api.Schema; -import org.apache.pulsar.client.impl.ClientBuilderImpl; -import org.junit.jupiter.api.Test; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import static org.apache.camel.test.junit5.TestSupport.body; - -public class PulsarConsumerInSynchronousTest extends PulsarTestSupport { - - private static final Logger LOGGER = LoggerFactory.getLogger(PulsarConsumerInAsynchronousTest.class); - - private static final String TOPIC_URI_SYNCHRONOUS_TRUE = "persistent://public/default/synchronousTrue"; - private static final String TOPIC_URI_SYNCHRONOUS_DEFAULT = "persistent://public/default/synchronousDefault"; - - private static final String TOPIC_URI_SYNCHRONOUS_TRUE_THROWS_EXCEPTION - = "persistent://public/default/synchronousTrueThrowsException"; - - private static final String TOPIC_URI_SYNCHRONOUS_TRUE_MANUAL_ACK = "persistent://public/default/synchronousTrueManualAck"; - - private static final String PRODUCER = "camel-producer-1"; - - @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_TRUE + "?numberOfConsumers=1&subscriptionType=Exclusive" - + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer" - + "&synchronous=true") - private Endpoint synchronousTrue; - - @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_DEFAULT + "?numberOfConsumers=1&subscriptionType=Exclusive" - + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer") - private Endpoint synchronousDefault; - - @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_TRUE_THROWS_EXCEPTION + "?numberOfConsumers=1&subscriptionType=Exclusive" - + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer" - + "&synchronous=true") - private Endpoint synchronousTrueThrowsException; - - @EndpointInject("pulsar:" + TOPIC_URI_SYNCHRONOUS_TRUE_MANUAL_ACK + "?numberOfConsumers=1&subscriptionType=Exclusive" - + "&subscriptionName=camel-subscription&consumerQueueSize=1&consumerName=camel-consumer" - + "&synchronous=true" + "&allowManualAcknowledgement=true" + "&ackTimeoutMillis=1000") - private Endpoint synchronousTrueManualAck; - - @EndpointInject("mock:result") - private MockEndpoint to; - - private CountDownLatch countDownLatch; - - @Override - protected RouteBuilder createRouteBuilder() { - return new RouteBuilder() { - - Processor processor = new Processor() { - @Override - public void process(final Exchange exchange) throws InterruptedException { - LOGGER.info("Processing message {}", exchange.getIn().getBody()); - countDownLatch.countDown(); - countDownLatch.await(20, TimeUnit.SECONDS); - } - }; - - Processor manualAckProcessor = new Processor() { - @Override - public void process(final Exchange exchange) throws PulsarClientException { - LOGGER.info("Processing message {}", exchange.getIn().getBody()); - PulsarMessageReceipt receipt = (PulsarMessageReceipt) exchange.getIn().getHeader( - PulsarMessageHeaders.MESSAGE_RECEIPT); - receipt.acknowledge(); - } - }; - - @Override - public void configure() { - - from(synchronousTrue) - .threads(2) - .process(processor) - .end() - .to(to); - - from(synchronousDefault) - .threads(2) - .process(processor) - .end() - .to(to); - - from(synchronousTrueThrowsException) - .threads(2) - .throwException(new RuntimeException("Processor throws exception.")) - .end() - .to(to); - - from(synchronousTrueManualAck) - .threads(2) - .process(manualAckProcessor) - .end() - .to(to); - } - }; - } - - @Override - protected Registry createCamelRegistry() throws Exception { - SimpleRegistry registry = new SimpleRegistry(); - - registerPulsarBeans(registry); - - return registry; - } - - private void registerPulsarBeans(SimpleRegistry registry) throws PulsarClientException { - PulsarClient pulsarClient = givenPulsarClient(); - AutoConfiguration autoConfiguration = new AutoConfiguration(null, null); - - registry.bind("pulsarClient", pulsarClient); - PulsarComponent comp = new PulsarComponent(context); - comp.setAutoConfiguration(autoConfiguration); - comp.setPulsarClient(pulsarClient); - registry.bind("pulsar", comp); - - } - - private PulsarClient givenPulsarClient() throws PulsarClientException { - return new ClientBuilderImpl().serviceUrl(getPulsarBrokerUrl()).ioThreads(1).listenerThreads(1).build(); - } - - @Test - public void testMessagesProcessedSynchronously() throws Exception { - processSynchronously(TOPIC_URI_SYNCHRONOUS_TRUE); - } - - @Test - public void testMessagesProcessedSynchronouslyByDefault() throws Exception { - processSynchronously(TOPIC_URI_SYNCHRONOUS_DEFAULT); - } - - public void processSynchronously(String topic) throws Exception { - - to.expectedMessageCount(2); - - countDownLatch = new CountDownLatch(2); - - Producer<String> producer = givenPulsarClient().newProducer(Schema.STRING).producerName(PRODUCER) - .topic(topic).create(); - - producer.send("One"); - producer.send("Two"); - - to.assertIsNotSatisfied(2000L); // ms - - } - - @Test - public void testMessageProcessedSynchronouslyThrowsException() throws Exception { - throwsException(TOPIC_URI_SYNCHRONOUS_TRUE_THROWS_EXCEPTION); - } - - public void throwsException(String topic) throws Exception { - to.expectedMessageCount(0); - Producer<String> producer = givenPulsarClient().newProducer(Schema.STRING).producerName(PRODUCER) - .topic(topic).create(); - - producer.send("One"); - - MockEndpoint.assertIsSatisfied(2, TimeUnit.SECONDS, to); - } - - @Test - public void testMessagesProcessedSynchronouslyManualAcknowledge() throws Exception { - manualAcknowledgement(TOPIC_URI_SYNCHRONOUS_TRUE_MANUAL_ACK); - } - - public void manualAcknowledgement(String topic) throws Exception { - to.expectsNoDuplicates(body()); - to.expectedMessageCount(1); - - Producer<String> producer = givenPulsarClient().newProducer(Schema.STRING).producerName(PRODUCER) - .topic(topic).create(); - - producer.send("Hello World!"); - - MockEndpoint.assertIsSatisfied(10, TimeUnit.SECONDS, to); - } - -} diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java index 41ac7db..f072bfe 100644 --- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java +++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java @@ -650,39 +650,6 @@ public interface PulsarEndpointBuilderFactory { doSetProperty("exchangePattern", exchangePattern); return this; } - /** - * Sets whether synchronous processing should be strictly used. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: advanced - * - * @param synchronous the value to set - * @return the dsl builder - */ - default AdvancedPulsarEndpointConsumerBuilder synchronous( - boolean synchronous) { - doSetProperty("synchronous", synchronous); - return this; - } - /** - * Sets whether synchronous processing should be strictly used. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: advanced - * - * @param synchronous the value to set - * @return the dsl builder - */ - default AdvancedPulsarEndpointConsumerBuilder synchronous( - String synchronous) { - doSetProperty("synchronous", synchronous); - return this; - } } /** @@ -1179,39 +1146,6 @@ public interface PulsarEndpointBuilderFactory { default PulsarEndpointProducerBuilder basic() { return (PulsarEndpointProducerBuilder) this; } - /** - * Sets whether synchronous processing should be strictly used. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: advanced - * - * @param synchronous the value to set - * @return the dsl builder - */ - default AdvancedPulsarEndpointProducerBuilder synchronous( - boolean synchronous) { - doSetProperty("synchronous", synchronous); - return this; - } - /** - * Sets whether synchronous processing should be strictly used. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: advanced - * - * @param synchronous the value to set - * @return the dsl builder - */ - default AdvancedPulsarEndpointProducerBuilder synchronous( - String synchronous) { - doSetProperty("synchronous", synchronous); - return this; - } } /** @@ -1236,37 +1170,6 @@ public interface PulsarEndpointBuilderFactory { default PulsarEndpointBuilder basic() { return (PulsarEndpointBuilder) this; } - /** - * Sets whether synchronous processing should be strictly used. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: advanced - * - * @param synchronous the value to set - * @return the dsl builder - */ - default AdvancedPulsarEndpointBuilder synchronous(boolean synchronous) { - doSetProperty("synchronous", synchronous); - return this; - } - /** - * Sets whether synchronous processing should be strictly used. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: advanced - * - * @param synchronous the value to set - * @return the dsl builder - */ - default AdvancedPulsarEndpointBuilder synchronous(String synchronous) { - doSetProperty("synchronous", synchronous); - return this; - } } /** diff --git a/docs/components/modules/ROOT/pages/pulsar-component.adoc b/docs/components/modules/ROOT/pages/pulsar-component.adoc index 75506aa..aff7b33 100644 --- a/docs/components/modules/ROOT/pages/pulsar-component.adoc +++ b/docs/components/modules/ROOT/pages/pulsar-component.adoc @@ -110,7 +110,7 @@ with the following path and query parameters: |=== -=== Query Parameters (34 parameters): +=== Query Parameters (33 parameters): [width="100%",cols="2,5,^1,2",options="header"] @@ -149,7 +149,6 @@ with the following path and query parameters: | *messageRoutingMode* (producer) | Message Routing Mode to use. There are 3 enums and the value can be one of: SinglePartition, RoundRobinPartition, CustomPartition | RoundRobinPartition | MessageRoutingMode | *producerName* (producer) | Name of the producer. If unset, lets Pulsar select a unique identifier. | | String | *sendTimeoutMs* (producer) | Send timeout in milliseconds | 30000 | int -| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used | false | boolean |=== // endpoint options: END
