This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 5cb3b82ad86 Regen for commit ab6b232c897b8a6bc1aaa3310f0400e39e7d3095
5cb3b82ad86 is described below
commit 5cb3b82ad8615eb353489ad995317905338f2155
Author: davsclaus <[email protected]>
AuthorDate: Thu Jan 5 10:04:48 2023 +0000
Regen for commit ab6b232c897b8a6bc1aaa3310f0400e39e7d3095
Signed-off-by: GitHub <[email protected]>
---
.../org/apache/camel/catalog/components/pulsar.json | 2 ++
.../component/pulsar/PulsarComponentConfigurer.java | 6 ++++++
.../camel/component/pulsar/PulsarEndpointConfigurer.java | 6 ++++++
.../camel/component/pulsar/PulsarEndpointUriFactory.java | 3 ++-
.../org/apache/camel/component/pulsar/pulsar.json | 2 ++
.../component/dsl/PulsarComponentBuilderFactory.java | 16 ++++++++++++++++
6 files changed, 34 insertions(+), 1 deletion(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
index 69d906d4ad2..62756df64aa 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
@@ -53,6 +53,7 @@
"batchingMaxMessages": { "kind": "property", "displayName": "Batching Max
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum size to batch messages." },
"batchingMaxPublishDelayMicros": { "kind": "property", "displayName":
"Batching Max Publish Delay Micros", "group": "producer", "label": "producer",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum time period
within which the messages sent will be batc [...]
"blockIfQueueFull": { "kind": "property", "displayName": "Block If Queue
Full", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Whether to block the producing thread if
pending messages queue is full or to throw a Prod [...]
+ "chunkingEnabled": { "kind": "property", "displayName": "Chunking
Enabled", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Control whether chunking of messages is
enabled for the producer." },
"compressionType": { "kind": "property", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "org.apache.pulsar.client.api.CompressionType", "enum": [
"NONE", "LZ4", "ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Comp [...]
"initialSequenceId": { "kind": "property", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
@@ -118,6 +119,7 @@
"batchingMaxMessages": { "kind": "parameter", "displayName": "Batching Max
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum size to batch messages." },
"batchingMaxPublishDelayMicros": { "kind": "parameter", "displayName":
"Batching Max Publish Delay Micros", "group": "producer", "label": "producer",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum time
period within which the messages sent will [...]
"blockIfQueueFull": { "kind": "parameter", "displayName": "Block If Queue
Full", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Whether to block the producing thread if
pending messages queue is full or to throw [...]
+ "chunkingEnabled": { "kind": "parameter", "displayName": "Chunking
Enabled", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Control whether chunking of messages is
enabled for the producer." },
"compressionType": { "kind": "parameter", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "org.apache.pulsar.client.api.CompressionType", "enum": [
"NONE", "LZ4", "ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description" [...]
"initialSequenceId": { "kind": "parameter", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"maxPendingMessages": { "kind": "parameter", "displayName": "Max Pending
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Size of the pending massages queue. When
the queue is full, by default, any further s [...]
diff --git
a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
index 97dab737df9..05665cb3a67 100644
---
a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
+++
b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
@@ -56,6 +56,8 @@ public class PulsarComponentConfigurer extends
PropertyConfigurerSupport impleme
case "blockIfQueueFull":
getOrCreateConfiguration(target).setBlockIfQueueFull(property(camelContext,
boolean.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
+ case "chunkingenabled":
+ case "chunkingEnabled":
getOrCreateConfiguration(target).setChunkingEnabled(property(camelContext,
boolean.class, value)); return true;
case "compressiontype":
case "compressionType":
getOrCreateConfiguration(target).setCompressionType(property(camelContext,
org.apache.pulsar.client.api.CompressionType.class, value)); return true;
case "configuration": target.setConfiguration(property(camelContext,
org.apache.camel.component.pulsar.PulsarConfiguration.class, value)); return
true;
@@ -153,6 +155,8 @@ public class PulsarComponentConfigurer extends
PropertyConfigurerSupport impleme
case "blockIfQueueFull": return boolean.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
+ case "chunkingenabled":
+ case "chunkingEnabled": return boolean.class;
case "compressiontype":
case "compressionType": return
org.apache.pulsar.client.api.CompressionType.class;
case "configuration": return
org.apache.camel.component.pulsar.PulsarConfiguration.class;
@@ -246,6 +250,8 @@ public class PulsarComponentConfigurer extends
PropertyConfigurerSupport impleme
case "blockIfQueueFull": return
getOrCreateConfiguration(target).isBlockIfQueueFull();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
+ case "chunkingenabled":
+ case "chunkingEnabled": return
getOrCreateConfiguration(target).isChunkingEnabled();
case "compressiontype":
case "compressionType": return
getOrCreateConfiguration(target).getCompressionType();
case "configuration": return target.getConfiguration();
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 08be79b9ea5..a35d5b6413a 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
@@ -45,6 +45,8 @@ public class PulsarEndpointConfigurer extends
PropertyConfigurerSupport implemen
case "blockIfQueueFull":
target.getPulsarConfiguration().setBlockIfQueueFull(property(camelContext,
boolean.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
+ case "chunkingenabled":
+ case "chunkingEnabled":
target.getPulsarConfiguration().setChunkingEnabled(property(camelContext,
boolean.class, value)); return true;
case "compressiontype":
case "compressionType":
target.getPulsarConfiguration().setCompressionType(property(camelContext,
org.apache.pulsar.client.api.CompressionType.class, value)); return true;
case "consumername":
@@ -132,6 +134,8 @@ public class PulsarEndpointConfigurer extends
PropertyConfigurerSupport implemen
case "blockIfQueueFull": return boolean.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
+ case "chunkingenabled":
+ case "chunkingEnabled": return boolean.class;
case "compressiontype":
case "compressionType": return
org.apache.pulsar.client.api.CompressionType.class;
case "consumername":
@@ -220,6 +224,8 @@ public class PulsarEndpointConfigurer extends
PropertyConfigurerSupport implemen
case "blockIfQueueFull": return
target.getPulsarConfiguration().isBlockIfQueueFull();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
+ case "chunkingenabled":
+ case "chunkingEnabled": return
target.getPulsarConfiguration().isChunkingEnabled();
case "compressiontype":
case "compressionType": return
target.getPulsarConfiguration().getCompressionType();
case "consumername":
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 3bb04d4d8c6..f798f88248a 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
@@ -21,7 +21,7 @@ public class PulsarEndpointUriFactory extends
org.apache.camel.support.component
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(44);
+ Set<String> props = new HashSet<>(45);
props.add("ackGroupTimeMillis");
props.add("ackTimeoutMillis");
props.add("ackTimeoutRedeliveryBackoff");
@@ -34,6 +34,7 @@ public class PulsarEndpointUriFactory extends
org.apache.camel.support.component
props.add("batchingMaxPublishDelayMicros");
props.add("blockIfQueueFull");
props.add("bridgeErrorHandler");
+ props.add("chunkingEnabled");
props.add("compressionType");
props.add("consumerName");
props.add("consumerNamePrefix");
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 69d906d4ad2..62756df64aa 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
@@ -53,6 +53,7 @@
"batchingMaxMessages": { "kind": "property", "displayName": "Batching Max
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum size to batch messages." },
"batchingMaxPublishDelayMicros": { "kind": "property", "displayName":
"Batching Max Publish Delay Micros", "group": "producer", "label": "producer",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum time period
within which the messages sent will be batc [...]
"blockIfQueueFull": { "kind": "property", "displayName": "Block If Queue
Full", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Whether to block the producing thread if
pending messages queue is full or to throw a Prod [...]
+ "chunkingEnabled": { "kind": "property", "displayName": "Chunking
Enabled", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Control whether chunking of messages is
enabled for the producer." },
"compressionType": { "kind": "property", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "org.apache.pulsar.client.api.CompressionType", "enum": [
"NONE", "LZ4", "ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Comp [...]
"initialSequenceId": { "kind": "property", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
@@ -118,6 +119,7 @@
"batchingMaxMessages": { "kind": "parameter", "displayName": "Batching Max
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum size to batch messages." },
"batchingMaxPublishDelayMicros": { "kind": "parameter", "displayName":
"Batching Max Publish Delay Micros", "group": "producer", "label": "producer",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum time
period within which the messages sent will [...]
"blockIfQueueFull": { "kind": "parameter", "displayName": "Block If Queue
Full", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Whether to block the producing thread if
pending messages queue is full or to throw [...]
+ "chunkingEnabled": { "kind": "parameter", "displayName": "Chunking
Enabled", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Control whether chunking of messages is
enabled for the producer." },
"compressionType": { "kind": "parameter", "displayName": "Compression
Type", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType": "org.apache.pulsar.client.api.CompressionType", "enum": [
"NONE", "LZ4", "ZLIB", "ZSTD", "SNAPPY" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "NONE", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description" [...]
"initialSequenceId": { "kind": "parameter", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"maxPendingMessages": { "kind": "parameter", "displayName": "Max Pending
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Size of the pending massages queue. When
the queue is full, by default, any further s [...]
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
index 5391d515161..9de1d34e8e0 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
@@ -569,6 +569,21 @@ public interface PulsarComponentBuilderFactory {
doSetProperty("blockIfQueueFull", blockIfQueueFull);
return this;
}
+ /**
+ * Control whether chunking of messages is enabled for the producer.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: producer
+ *
+ * @param chunkingEnabled the value to set
+ * @return the dsl builder
+ */
+ default PulsarComponentBuilder chunkingEnabled(boolean
chunkingEnabled) {
+ doSetProperty("chunkingEnabled", chunkingEnabled);
+ return this;
+ }
/**
* Compression type to use.
*
@@ -836,6 +851,7 @@ public interface PulsarComponentBuilderFactory {
case "batchingMaxMessages":
getOrCreateConfiguration((PulsarComponent)
component).setBatchingMaxMessages((int) value); return true;
case "batchingMaxPublishDelayMicros":
getOrCreateConfiguration((PulsarComponent)
component).setBatchingMaxPublishDelayMicros((long) value); return true;
case "blockIfQueueFull":
getOrCreateConfiguration((PulsarComponent)
component).setBlockIfQueueFull((boolean) value); return true;
+ case "chunkingEnabled": getOrCreateConfiguration((PulsarComponent)
component).setChunkingEnabled((boolean) value); return true;
case "compressionType": getOrCreateConfiguration((PulsarComponent)
component).setCompressionType((org.apache.pulsar.client.api.CompressionType)
value); return true;
case "initialSequenceId":
getOrCreateConfiguration((PulsarComponent)
component).setInitialSequenceId((long) value); return true;
case "lazyStartProducer": ((PulsarComponent)
component).setLazyStartProducer((boolean) value); return true;
