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-spring-boot.git
commit 0e482c04c73ccca0deda6969014b6f41b2d1f383
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jan 6 06:43:54 2023 +0100
Regen
---
.../apache/camel/springboot/catalog/components.properties | 2 +-
.../apache/camel/springboot/catalog/components/plc4x.json | 1 +
.../apache/camel/springboot/catalog/components/pulsar.json | 2 ++
.../camel-pulsar-starter/src/main/docs/pulsar.json | 7 +++++++
.../pulsar/springboot/PulsarComponentConfiguration.java | 12 ++++++++++++
components-starter/camel-spark-starter/pom.xml | 8 ++++++++
6 files changed, 31 insertions(+), 1 deletion(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
index d4290624406..7d6b5a4cd03 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components.properties
@@ -348,4 +348,4 @@ xslt
xslt-saxon
zendesk
zookeeper
-zookeeper-master
+zookeeper-master
\ No newline at end of file
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/plc4x.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/plc4x.json
index 0e21ed6262a..eb3cdb131f2 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/plc4x.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/plc4x.json
@@ -28,6 +28,7 @@
},
"properties": {
"driver": { "kind": "path", "displayName": "Driver", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "PLC4X connection string for the
connection to the target" },
+ "autoReconnect": { "kind": "parameter", "displayName": "Auto Reconnect",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to
reconnect when no connection is present upon doing a request" },
"tags": { "kind": "parameter", "displayName": "Tags", "group": "common",
"label": "", "required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
tags to read as Map containing the tag name associated to its query" },
"period": { "kind": "parameter", "displayName": "Period", "group":
"consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Interval on which the Trigger should be
checked" },
"trigger": { "kind": "parameter", "displayName": "Trigger", "group":
"consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Query to a trigger. On a
rising edge of the trigger, the tags will be read once" },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
index c765400d955..d3a107fd362 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/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-starter/camel-pulsar-starter/src/main/docs/pulsar.json
b/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
index 02a2f511d55..43eb3630586 100644
--- a/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
+++ b/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
@@ -106,6 +106,13 @@
"sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.pulsar.chunking-enabled",
+ "type": "java.lang.Boolean",
+ "description": "Control whether chunking of messages is enabled for the
producer.",
+ "sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
+ "defaultValue": false
+ },
{
"name": "camel.component.pulsar.compression-type",
"type": "org.apache.pulsar.client.api.CompressionType",
diff --git
a/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
b/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
index 82d482689b2..1ea76c8e1f1 100644
---
a/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
+++
b/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
@@ -208,6 +208,10 @@ public class PulsarComponentConfiguration
* or to throw a ProducerQueueIsFullError
*/
private Boolean blockIfQueueFull = false;
+ /**
+ * Control whether chunking of messages is enabled for the producer.
+ */
+ private Boolean chunkingEnabled = false;
/**
* Compression type to use
*/
@@ -533,6 +537,14 @@ public class PulsarComponentConfiguration
this.blockIfQueueFull = blockIfQueueFull;
}
+ public Boolean getChunkingEnabled() {
+ return chunkingEnabled;
+ }
+
+ public void setChunkingEnabled(Boolean chunkingEnabled) {
+ this.chunkingEnabled = chunkingEnabled;
+ }
+
public CompressionType getCompressionType() {
return compressionType;
}
diff --git a/components-starter/camel-spark-starter/pom.xml
b/components-starter/camel-spark-starter/pom.xml
index 10c7607920b..f3360402809 100644
--- a/components-starter/camel-spark-starter/pom.xml
+++ b/components-starter/camel-spark-starter/pom.xml
@@ -44,6 +44,14 @@
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
</exclusion>
+ <exclusion>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-core</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-slf4j-impl</artifactId>
+ </exclusion>
</exclusions>
<!--END OF GENERATED CODE-->
</dependency>
