You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/05/02 11:03:09 UTC
[camel] 05/05: CAMEL-13453 - Regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2c325c487f27839206ee91925c54e8c8de7a6f70
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu May 2 13:01:00 2019 +0200
CAMEL-13453 - Regen
---
.../src/main/docs/azure-queue-component.adoc | 11 +-
.../QueueServiceComponentConfiguration.java | 116 +++++++++++++++++++++
2 files changed, 126 insertions(+), 1 deletion(-)
diff --git a/components/camel-azure/src/main/docs/azure-queue-component.adoc b/components/camel-azure/src/main/docs/azure-queue-component.adoc
index b0a5850..ac2df86 100644
--- a/components/camel-azure/src/main/docs/azure-queue-component.adoc
+++ b/components/camel-azure/src/main/docs/azure-queue-component.adoc
@@ -35,7 +35,16 @@ to("file://queuedirectory");
// component options: START
-The Azure Storage Queue Service component has no options.
+The Azure Storage Queue Service component supports 2 options, which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *configuration* (advanced) | The Queue Service configuration | | QueueService Configuration
+| *resolveProperty Placeholders* (advanced) | Whether the component should resolve property placeholders on itself when starting. Only properties which are of String type can use property placeholders. | true | boolean
+|===
// component options: END
diff --git a/platforms/spring-boot/components-starter/camel-azure-starter/src/main/java/org/apache/camel/component/azure/queue/springboot/QueueServiceComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-azure-starter/src/main/java/org/apache/camel/component/azure/queue/springboot/QueueServiceComponentConfiguration.java
index e26ce54..7717e17 100644
--- a/platforms/spring-boot/components-starter/camel-azure-starter/src/main/java/org/apache/camel/component/azure/queue/springboot/QueueServiceComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-azure-starter/src/main/java/org/apache/camel/component/azure/queue/springboot/QueueServiceComponentConfiguration.java
@@ -17,6 +17,9 @@
package org.apache.camel.component.azure.queue.springboot;
import javax.annotation.Generated;
+import com.microsoft.azure.storage.StorageCredentials;
+import com.microsoft.azure.storage.queue.CloudQueue;
+import org.apache.camel.component.azure.queue.QueueServiceOperations;
import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
import org.springframework.boot.context.properties.ConfigurationProperties;
@@ -38,12 +41,25 @@ public class QueueServiceComponentConfiguration
*/
private Boolean enabled;
/**
+ * The Queue Service configuration
+ */
+ private QueueServiceConfigurationNestedConfiguration configuration;
+ /**
* Whether the component should resolve property placeholders on itself when
* starting. Only properties which are of String type can use property
* placeholders.
*/
private Boolean resolvePropertyPlaceholders = true;
+ public QueueServiceConfigurationNestedConfiguration getConfiguration() {
+ return configuration;
+ }
+
+ public void setConfiguration(
+ QueueServiceConfigurationNestedConfiguration configuration) {
+ this.configuration = configuration;
+ }
+
public Boolean getResolvePropertyPlaceholders() {
return resolvePropertyPlaceholders;
}
@@ -52,4 +68,104 @@ public class QueueServiceComponentConfiguration
Boolean resolvePropertyPlaceholders) {
this.resolvePropertyPlaceholders = resolvePropertyPlaceholders;
}
+
+ public static class QueueServiceConfigurationNestedConfiguration {
+ public static final Class CAMEL_NESTED_CLASS = org.apache.camel.component.azure.queue.QueueServiceConfiguration.class;
+ /**
+ * The queue resource name
+ */
+ private String queueName;
+ /**
+ * The queue service client
+ */
+ private CloudQueue azureQueueClient;
+ /**
+ * Queue service operation hint to the producer
+ */
+ private QueueServiceOperations operation = QueueServiceOperations.listQueues;
+ /**
+ * Message Time To Live in seconds
+ */
+ private Integer messageTimeToLive;
+ /**
+ * Message Visibility Delay in seconds
+ */
+ private Integer messageVisibilityDelay;
+ /**
+ * Set a prefix which can be used for listing the queues
+ */
+ private String queuePrefix;
+ /**
+ * Set the Azure account name
+ */
+ private String accountName;
+ /**
+ * Set the storage credentials, required in most cases
+ */
+ private StorageCredentials credentials;
+
+ public String getQueueName() {
+ return queueName;
+ }
+
+ public void setQueueName(String queueName) {
+ this.queueName = queueName;
+ }
+
+ public CloudQueue getAzureQueueClient() {
+ return azureQueueClient;
+ }
+
+ public void setAzureQueueClient(CloudQueue azureQueueClient) {
+ this.azureQueueClient = azureQueueClient;
+ }
+
+ public QueueServiceOperations getOperation() {
+ return operation;
+ }
+
+ public void setOperation(QueueServiceOperations operation) {
+ this.operation = operation;
+ }
+
+ public Integer getMessageTimeToLive() {
+ return messageTimeToLive;
+ }
+
+ public void setMessageTimeToLive(Integer messageTimeToLive) {
+ this.messageTimeToLive = messageTimeToLive;
+ }
+
+ public Integer getMessageVisibilityDelay() {
+ return messageVisibilityDelay;
+ }
+
+ public void setMessageVisibilityDelay(Integer messageVisibilityDelay) {
+ this.messageVisibilityDelay = messageVisibilityDelay;
+ }
+
+ public String getQueuePrefix() {
+ return queuePrefix;
+ }
+
+ public void setQueuePrefix(String queuePrefix) {
+ this.queuePrefix = queuePrefix;
+ }
+
+ public String getAccountName() {
+ return accountName;
+ }
+
+ public void setAccountName(String accountName) {
+ this.accountName = accountName;
+ }
+
+ public StorageCredentials getCredentials() {
+ return credentials;
+ }
+
+ public void setCredentials(StorageCredentials credentials) {
+ this.credentials = credentials;
+ }
+ }
}
\ No newline at end of file