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 3c00c7f Regen
3c00c7f is described below
commit 3c00c7fa08143c7ea1f6a36eeb7eb8982f90907a
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Aug 24 08:19:33 2021 +0200
Regen
---
.../camel/springboot/catalog/components/as2.json | 5 +--
.../springboot/catalog/components/pulsar.json | 6 ++++
.../src/main/docs/pulsar-starter.adoc | 5 ++-
.../springboot/PulsarComponentConfiguration.java | 37 ++++++++++++++++++++++
docs/modules/ROOT/pages/pulsar-starter.adoc | 5 ++-
tooling/camel-spring-boot-dependencies/pom.xml | 2 +-
6 files changed, 55 insertions(+), 5 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/as2.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/as2.json
index b8eb50c..5e5b7e6 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/as2.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/as2.json
@@ -36,6 +36,7 @@
"as2MessageStructure": { "kind": "parameter", "displayName": "As2 Message
Structure", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.component.as2.api.AS2MessageStructure",
"enum": [ "PLAIN", "SIGNED", "ENCRYPTED", "SIGNED_ENCRYPTED",
"PLAIN_COMPRESSED", "SIGNED_COMPRESSED", "ENCRYPTED_COMPRESSED",
"ENCRYPTED_COMPRESSED_SIGNED" ], "deprecated": false, "autowired": false,
"secret": false, "configurationClass": "org.apache.camel.compo [...]
"as2To": { "kind": "parameter", "displayName": "As2 To", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.as2.AS2Configuration",
"configurationField": "configuration", "description": "The value of the AS2To
header of AS2 message." },
"as2Version": { "kind": "parameter", "displayName": "As2 Version",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "1.0", "1.1" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1.1",
"configurationClass": "org.apache.camel.component.as2.AS2Configuration",
"configurationField": "configuration", "description": "The version of the AS2
protocol." },
+ "attachedFileName": { "kind": "parameter", "displayName": "Attached File
Name", "group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.as2.AS2Configuration", "configurationField":
"configuration", "description": "The name of the attached file" },
"clientFqdn": { "kind": "parameter", "displayName": "Client Fqdn",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "camel.apache.org", "configurationClass":
"org.apache.camel.component.as2.AS2Configuration", "configurationField":
"configuration", "description": "The Client Fully Qualified Domain Name (FQDN).
Used in message ids sent by endpoint." },
"compressionAlgorithm": { "kind": "parameter", "displayName": "Compression
Algorithm", "group": "common", "label": "", "required": false, "type":
"object", "javaType":
"org.apache.camel.component.as2.api.AS2CompressionAlgorithm", "enum": [ "ZLIB"
], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.as2.AS2Configuration",
"configurationField": "configuration", "description": "The algorithm used to
compress EDI message." },
"decryptingPrivateKey": { "kind": "parameter", "displayName": "Decrypting
Private Key", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "java.security.PrivateKey", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.as2.AS2Configuration", "configurationField":
"configuration", "description": "The key used to encrypt the EDI message." },
@@ -64,11 +65,11 @@
"lazyStartProducer": { "kind": "parameter", "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 sta [...]
},
"apis": {
- "client": { "consumerOnly": false, "producerOnly": true, "description":
"Sends EDI Messages over HTTP", "methods": { "send": { "description": "Send
ediMessage to trading partner", "signatures": [
"org.apache.http.protocol.HttpCoreContext send(String ediMessage, String
requestUri, String subject, String from, String as2From, String as2To,
org.apache.camel.component.as2.api.AS2MessageStructure as2MessageStructure,
org.apache.http.entity.ContentType ediMessageContentType, String ediMess [...]
+ "client": { "consumerOnly": false, "producerOnly": true, "description":
"Sends EDI Messages over HTTP", "methods": { "send": { "description": "Send
ediMessage to trading partner", "signatures": [
"org.apache.http.protocol.HttpCoreContext send(String ediMessage, String
requestUri, String subject, String from, String as2From, String as2To,
org.apache.camel.component.as2.api.AS2MessageStructure as2MessageStructure,
org.apache.http.entity.ContentType ediMessageContentType, String ediMess [...]
"server": { "consumerOnly": true, "producerOnly": false, "description":
"Receives EDI Messages over HTTP", "methods": { "listen": { "description": "",
"signatures": [ "void listen(String requestUriPattern,
org.apache.http.protocol.HttpRequestHandler handler)" ] } } }
},
"apiProperties": {
- "client": { "methods": { "send": { "properties": { "as2From": { "kind":
"parameter", "displayName": "As2 From", "group": "producer", "label": "",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description": "AS2
name of sender", "optional": false }, "as2MessageStructure": { "kind":
"parameter", "displayName": "As2 Message Structure", "group": "producer",
"label": "", "required": false, "type": "object", [...]
+ "client": { "methods": { "send": { "properties": { "as2From": { "kind":
"parameter", "displayName": "As2 From", "group": "producer", "label": "",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "description": "AS2
name of sender", "optional": false }, "as2MessageStructure": { "kind":
"parameter", "displayName": "As2 Message Structure", "group": "producer",
"label": "", "required": false, "type": "object", [...]
"server": { "methods": { "listen": { "properties": { "requestUriPattern":
{ "kind": "parameter", "displayName": "Request Uri Pattern", "group":
"consumer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "", "optional": false } } } } }
}
}
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 56e794e..74faaa7 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
@@ -22,7 +22,10 @@
"lenientProperties": false
},
"componentProperties": {
+ "authenticationClass": { "kind": "property", "displayName":
"Authentication Class", "group": "common", "label": "common", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The Authentication FQCN to be used while
creating the client from URI" },
+ "authenticationParams": { "kind": "property", "displayName":
"Authentication Params", "group": "common", "label": "common", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The Authentication Parameters to be used while
creating the client from URI" },
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.pulsar.PulsarConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description":
"Allows to pre-configure the Pulsar component with common options that the
endpoints will reuse." },
+ "serviceUrl": { "kind": "property", "displayName": "Service Url", "group":
"common", "label": "common", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The Pulsar Service URL
to point while creating the client from URI" },
"ackGroupTimeMillis": { "kind": "property", "displayName": "Ack Group Time
Millis", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 100, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Group the consumer acknowledgments for the
specified time in milliseconds - defaults to 100" },
"ackTimeoutMillis": { "kind": "property", "displayName": "Ack Timeout
Millis", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Timeout for unacknowledged messages in
milliseconds - defaults to 10000" },
"allowManualAcknowledgement": { "kind": "property", "displayName": "Allow
Manual Acknowledgement", "group": "consumer", "label": "consumer", "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 allow manual
message acknowledgements. If this option is ena [...]
@@ -66,6 +69,9 @@
"tenant": { "kind": "path", "displayName": "Tenant", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The tenant" },
"namespace": { "kind": "path", "displayName": "Namespace", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The namespace" },
"topic": { "kind": "path", "displayName": "Topic", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The topic" },
+ "authenticationClass": { "kind": "parameter", "displayName":
"Authentication Class", "group": "common", "label": "common", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The Authentication FQCN to be used while
creating the client from URI" },
+ "authenticationParams": { "kind": "parameter", "displayName":
"Authentication Params", "group": "common", "label": "common", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The Authentication Parameters to be used
while creating the client from URI" },
+ "serviceUrl": { "kind": "parameter", "displayName": "Service Url",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "The Pulsar Service URL to point while
creating the client from URI" },
"ackGroupTimeMillis": { "kind": "parameter", "displayName": "Ack Group
Time Millis", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 100, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Group the consumer acknowledgments for
the specified time in milliseconds - defaults [...]
"ackTimeoutMillis": { "kind": "parameter", "displayName": "Ack Timeout
Millis", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 10000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Timeout for unacknowledged messages in
milliseconds - defaults to 10000" },
"allowManualAcknowledgement": { "kind": "parameter", "displayName": "Allow
Manual Acknowledgement", "group": "consumer", "label": "consumer", "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 allow
manual message acknowledgements. If this option [...]
diff --git
a/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
b/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
index 5b62e4f..bfb573a 100644
--- a/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
+++ b/components-starter/camel-pulsar-starter/src/main/docs/pulsar-starter.adoc
@@ -17,7 +17,7 @@ When using pulsar with Spring Boot make sure to use the
following Maven dependen
----
-The component supports 39 options, which are listed below.
+The component supports 42 options, which are listed below.
@@ -27,6 +27,8 @@ The component supports 39 options, which are listed below.
| *camel.component.pulsar.ack-group-time-millis* | Group the consumer
acknowledgments for the specified time in milliseconds - defaults to 100 | 100
| Long
| *camel.component.pulsar.ack-timeout-millis* | Timeout for unacknowledged
messages in milliseconds - defaults to 10000 | 10000 | Long
| *camel.component.pulsar.allow-manual-acknowledgement* | Whether to allow
manual message acknowledgements. If this option is enabled, then messages are
not acknowledged automatically after successful route completion. Instead, an
instance of PulsarMessageReceipt is stored as a header on the
org.apache.camel.Exchange. Messages can then be acknowledged using
PulsarMessageReceipt at any time before the ackTimeout occurs. | false | Boolean
+| *camel.component.pulsar.authentication-class* | The Authentication FQCN to
be used while creating the client from URI | | String
+| *camel.component.pulsar.authentication-params* | The Authentication
Parameters to be used while creating the client from URI | | String
| *camel.component.pulsar.auto-configuration* | The pulsar auto configuration.
The option is a org.apache.camel.component.pulsar.utils.AutoConfiguration type.
| | AutoConfiguration
| *camel.component.pulsar.autowired-enabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | Boolean
| *camel.component.pulsar.batcher-builder* | Control batching method used by
the producer. The option is a org.apache.pulsar.client.api.BatcherBuilder type.
| | BatcherBuilder
@@ -58,6 +60,7 @@ The component supports 39 options, which are listed below.
| *camel.component.pulsar.pulsar-message-receipt-factory* | Provide a factory
to create an alternate implementation of PulsarMessageReceipt. The option is a
org.apache.camel.component.pulsar.PulsarMessageReceiptFactory type. | |
PulsarMessageReceiptFactory
| *camel.component.pulsar.read-compacted* | Enable compacted topic reading. |
false | Boolean
| *camel.component.pulsar.send-timeout-ms* | Send timeout in milliseconds |
30000 | Integer
+| *camel.component.pulsar.service-url* | The Pulsar Service URL to point while
creating the client from URI | | String
| *camel.component.pulsar.subscription-initial-position* | Control the initial
position in the topic of a newly created subscription. Default is latest
message. | | SubscriptionInitialPosition
| *camel.component.pulsar.subscription-name* | Name of the subscription to use
| subs | String
| *camel.component.pulsar.subscription-topics-mode* | Determines to which
topics this consumer should be subscribed to - Persistent, Non-Persistent, or
both. Only used with pattern subscriptions. | | RegexSubscriptionMode
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 a6c2d4d..3a8f70b 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
@@ -49,12 +49,25 @@ public class PulsarComponentConfiguration
*/
private Boolean enabled;
/**
+ * The Authentication FQCN to be used while creating the client from URI
+ */
+ private String authenticationClass;
+ /**
+ * The Authentication Parameters to be used while creating the client from
+ * URI
+ */
+ private String authenticationParams;
+ /**
* Allows to pre-configure the Pulsar component with common options that
the
* endpoints will reuse. The option is a
* org.apache.camel.component.pulsar.PulsarConfiguration type.
*/
private PulsarConfiguration configuration;
/**
+ * The Pulsar Service URL to point while creating the client from URI
+ */
+ private String serviceUrl;
+ /**
* Group the consumer acknowledgments for the specified time in
milliseconds
* - defaults to 100
*/
@@ -252,6 +265,22 @@ public class PulsarComponentConfiguration
*/
private PulsarClient pulsarClient;
+ public String getAuthenticationClass() {
+ return authenticationClass;
+ }
+
+ public void setAuthenticationClass(String authenticationClass) {
+ this.authenticationClass = authenticationClass;
+ }
+
+ public String getAuthenticationParams() {
+ return authenticationParams;
+ }
+
+ public void setAuthenticationParams(String authenticationParams) {
+ this.authenticationParams = authenticationParams;
+ }
+
public PulsarConfiguration getConfiguration() {
return configuration;
}
@@ -260,6 +289,14 @@ public class PulsarComponentConfiguration
this.configuration = configuration;
}
+ public String getServiceUrl() {
+ return serviceUrl;
+ }
+
+ public void setServiceUrl(String serviceUrl) {
+ this.serviceUrl = serviceUrl;
+ }
+
public Long getAckGroupTimeMillis() {
return ackGroupTimeMillis;
}
diff --git a/docs/modules/ROOT/pages/pulsar-starter.adoc
b/docs/modules/ROOT/pages/pulsar-starter.adoc
index 5b62e4f..bfb573a 100644
--- a/docs/modules/ROOT/pages/pulsar-starter.adoc
+++ b/docs/modules/ROOT/pages/pulsar-starter.adoc
@@ -17,7 +17,7 @@ When using pulsar with Spring Boot make sure to use the
following Maven dependen
----
-The component supports 39 options, which are listed below.
+The component supports 42 options, which are listed below.
@@ -27,6 +27,8 @@ The component supports 39 options, which are listed below.
| *camel.component.pulsar.ack-group-time-millis* | Group the consumer
acknowledgments for the specified time in milliseconds - defaults to 100 | 100
| Long
| *camel.component.pulsar.ack-timeout-millis* | Timeout for unacknowledged
messages in milliseconds - defaults to 10000 | 10000 | Long
| *camel.component.pulsar.allow-manual-acknowledgement* | Whether to allow
manual message acknowledgements. If this option is enabled, then messages are
not acknowledged automatically after successful route completion. Instead, an
instance of PulsarMessageReceipt is stored as a header on the
org.apache.camel.Exchange. Messages can then be acknowledged using
PulsarMessageReceipt at any time before the ackTimeout occurs. | false | Boolean
+| *camel.component.pulsar.authentication-class* | The Authentication FQCN to
be used while creating the client from URI | | String
+| *camel.component.pulsar.authentication-params* | The Authentication
Parameters to be used while creating the client from URI | | String
| *camel.component.pulsar.auto-configuration* | The pulsar auto configuration.
The option is a org.apache.camel.component.pulsar.utils.AutoConfiguration type.
| | AutoConfiguration
| *camel.component.pulsar.autowired-enabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | Boolean
| *camel.component.pulsar.batcher-builder* | Control batching method used by
the producer. The option is a org.apache.pulsar.client.api.BatcherBuilder type.
| | BatcherBuilder
@@ -58,6 +60,7 @@ The component supports 39 options, which are listed below.
| *camel.component.pulsar.pulsar-message-receipt-factory* | Provide a factory
to create an alternate implementation of PulsarMessageReceipt. The option is a
org.apache.camel.component.pulsar.PulsarMessageReceiptFactory type. | |
PulsarMessageReceiptFactory
| *camel.component.pulsar.read-compacted* | Enable compacted topic reading. |
false | Boolean
| *camel.component.pulsar.send-timeout-ms* | Send timeout in milliseconds |
30000 | Integer
+| *camel.component.pulsar.service-url* | The Pulsar Service URL to point while
creating the client from URI | | String
| *camel.component.pulsar.subscription-initial-position* | Control the initial
position in the topic of a newly created subscription. Default is latest
message. | | SubscriptionInitialPosition
| *camel.component.pulsar.subscription-name* | Name of the subscription to use
| subs | String
| *camel.component.pulsar.subscription-topics-mode* | Determines to which
topics this consumer should be subscribed to - Persistent, Non-Persistent, or
both. Only used with pattern subscriptions. | | RegexSubscriptionMode
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index a566a7c..9dd3bf5 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -73,7 +73,7 @@
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
- <version>1.2.76</version>
+ <version>1.2.78</version>
</dependency>
<dependency>
<groupId>com.azure</groupId>
