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
The following commit(s) were added to refs/heads/main by this push:
new 46bb6d4fc98 [create-pull-request] automated change
46bb6d4fc98 is described below
commit 46bb6d4fc98a6d1a659f097a07c52fd32d05bff3
Author: oscerd <osc...@users.noreply.github.com>
AuthorDate: Thu Oct 13 01:10:34 2022 +0000
[create-pull-request] automated change
---
.../camel/springboot/catalog/components/pulsar.json | 4 ++--
.../camel-pulsar-starter/src/main/docs/pulsar.json | 16 +++++++++-------
.../pulsar/springboot/PulsarComponentConfiguration.java | 5 +++++
3 files changed, 16 insertions(+), 9 deletions(-)
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 1ac6e60d769..b75d9beca0a 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
@@ -57,7 +57,7 @@
"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 [...]
"maxPendingMessages": { "kind": "property", "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":
"configuration", "description": "Size of the pending massages queue. When the
queue is full, by default, any further sends wi [...]
- "maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
50000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum number of pending messages for
partitioned to [...]
+ "maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 50000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum number of
pending messages for partitioned top [...]
"messageRouter": { "kind": "property", "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":
"configuration", "description": "Custom Message Router to use" },
"messageRoutingMode": { "kind": "property", "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",
"configuration [...]
"producerName": { "kind": "property", "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":
"configuration", "description": "Name of the producer. If unset, lets Pulsar
select a unique identifier." },
@@ -121,7 +121,7 @@
"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 [...]
- "maxPendingMessagesAcrossPartitions": { "kind": "parameter",
"displayName": "Max Pending Messages Across Partitions", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
50000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The maximum number of pending messages
for partiti [...]
+ "maxPendingMessagesAcrossPartitions": { "kind": "parameter",
"displayName": "Max Pending Messages Across Partitions", "group": "producer",
"label": "producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 50000,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "pulsarConfiguration", "description": "The maximum number
of pending messages for partitio [...]
"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." },
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 cce795ecaa8..02a2f511d55 100644
--- a/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
+++ b/components-starter/camel-pulsar-starter/src/main/docs/pulsar.json
@@ -177,13 +177,6 @@
"sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
"defaultValue": 1000
},
- {
- "name": "camel.component.pulsar.max-pending-messages-across-partitions",
- "type": "java.lang.Integer",
- "description": "The maximum number of pending messages for partitioned
topics. The maxPendingMessages value will be reduced if (number of partitions
maxPendingMessages) exceeds this value. Partitioned topics have a pending
message queue for each partition.",
- "sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
- "defaultValue": 50000
- },
{
"name": "camel.component.pulsar.max-redeliver-count",
"type": "java.lang.Integer",
@@ -305,6 +298,15 @@
"description": "Whether the topic is a pattern (regular expression) that
allows the consumer to subscribe to all matching topics in the namespace",
"sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
"defaultValue": false
+ },
+ {
+ "name": "camel.component.pulsar.max-pending-messages-across-partitions",
+ "type": "java.lang.Integer",
+ "description": "The maximum number of pending messages for partitioned
topics. The maxPendingMessages value will be reduced if (number of partitions
maxPendingMessages) exceeds this value. Partitioned topics have a pending
message queue for each partition.",
+ "sourceType":
"org.apache.camel.component.pulsar.springboot.PulsarComponentConfiguration",
+ "defaultValue": 50000,
+ "deprecated": true,
+ "deprecation": {}
}
],
"hints": []
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 dca33662710..82d482689b2 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
@@ -32,6 +32,7 @@ import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.RedeliveryBackoff;
import org.apache.pulsar.client.api.RegexSubscriptionMode;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import
org.springframework.boot.context.properties.DeprecatedConfigurationProperty;
/**
* Send and receive messages from/to Apache Pulsar messaging system.
@@ -238,6 +239,7 @@ public class PulsarComponentConfiguration
* maxPendingMessages) exceeds this value. Partitioned topics have a
pending
* message queue for each partition.
*/
+ @Deprecated
private Integer maxPendingMessagesAcrossPartitions = 50000;
/**
* Custom Message Router to use. The option is a
@@ -563,10 +565,13 @@ public class PulsarComponentConfiguration
this.maxPendingMessages = maxPendingMessages;
}
+ @Deprecated
+ @DeprecatedConfigurationProperty
public Integer getMaxPendingMessagesAcrossPartitions() {
return maxPendingMessagesAcrossPartitions;
}
+ @Deprecated
public void setMaxPendingMessagesAcrossPartitions(
Integer maxPendingMessagesAcrossPartitions) {
this.maxPendingMessagesAcrossPartitions =
maxPendingMessagesAcrossPartitions;
