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 a03c3b591344a5b9079e14b1c1857a5656cb4525
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Apr 16 14:52:35 2021 +0200
CAMEL-16513 - Camel-Azure-Storage-Queue: Don't create queue automatically
by default
---
.../camel/catalog/docs/azure-storage-queue-component.adoc | 4 ++--
.../component/azure/storage/queue/azure-storage-queue.json | 4 ++--
.../src/main/docs/azure-storage-queue-component.adoc | 4 ++--
.../component/azure/storage/queue/QueueConfiguration.java | 4 ++--
.../storage/queue/integration/StorageQueueProducerIT.java | 10 ++++------
.../dsl/AzureStorageQueueComponentBuilderFactory.java | 2 +-
.../builder/endpoint/dsl/QueueEndpointBuilderFactory.java | 4 ++--
.../modules/ROOT/pages/azure-storage-queue-component.adoc | 4 ++--
8 files changed, 17 insertions(+), 19 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
index 3b9e9e0..a8e6c12 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-queue-component.adoc
@@ -72,7 +72,7 @@ The Azure Storage Queue Service component supports 15
options, which are listed
| *configuration* (common) | The component configurations | |
QueueConfiguration
| *serviceClient* (common) | *Autowired* Service client to a storage account
to interact with the queue service. This client does not hold any state about a
particular storage account but is instead a convenient way of sending off
appropriate requests to the resource on the service. This client contains all
the operations for interacting with a queue account in Azure Storage.
Operations allowed by the client are creating, listing, and deleting queues,
retrieving and updating properties o [...]
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
-| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | true | boolean
+| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | false | boolean
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | Queue service operation hint to the producer. There
are 9 enums and the value can be one of: listQueues, createQueue, deleteQueue,
clearQueue, sendMessage, deleteMessage, receiveMessages, peekMessages,
updateMessage | | QueueOperationDefinition
| *autowiredEnabled* (advanced) | 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
@@ -119,7 +119,7 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
-| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | true | boolean
+| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | false | boolean
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | Queue service operation hint to the producer. There
are 9 enums and the value can be one of: listQueues, createQueue, deleteQueue,
clearQueue, sendMessage, deleteMessage, receiveMessages, peekMessages,
updateMessage | | QueueOperationDefinition
| *maxMessages* (queue) | Maximum number of messages to get, if there are less
messages exist in the queue than requested all the messages will be returned.
If left empty only 1 message will be retrieved, the allowed range is 1 to 32
messages. | 1 | Integer
diff --git
a/components/camel-azure/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
b/components/camel-azure/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
index 7492793..eaa6a68 100644
---
a/components/camel-azure/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
+++
b/components/camel-azure/camel-azure-storage-queue/src/generated/resources/org/apache/camel/component/azure/storage/queue/azure-storage-queue.json
@@ -25,7 +25,7 @@
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
"serviceClient": { "kind": "property", "displayName": "Service Client",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "com.azure.storage.queue.QueueServiceClient", "deprecated": false,
"deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Service client to a
storage account to interact with the [...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
- "createQueue": { "kind": "property", "displayName": "Create Queue",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "When is set to true, the
queue will be automatically created when sending messages to the q [...]
+ "createQueue": { "kind": "property", "displayName": "Create Queue",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "When is set to true, the
queue will be automatically created when sending messages to the [...]
"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 [...]
"operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.queue.QueueOperationDefinition",
"enum": [ "listQueues", "createQueue", "deleteQueue", "clearQueue",
"sendMessage", "deleteMessage", "receiveMessages", "peekMessages",
"updateMessage" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.compone [...]
"autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "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 t [...]
@@ -47,7 +47,7 @@
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
"pollStrategy": { "kind": "parameter", "displayName": "Poll Strategy",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation [...]
- "createQueue": { "kind": "parameter", "displayName": "Create Queue",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "When is set to true, the
queue will be automatically created when sending messages to the [...]
+ "createQueue": { "kind": "parameter", "displayName": "Create Queue",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "When is set to true, the
queue will be automatically created when sending messages to the [...]
"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 [...]
"operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.azure.storage.queue.QueueOperationDefinition",
"enum": [ "listQueues", "createQueue", "deleteQueue", "clearQueue",
"sendMessage", "deleteMessage", "receiveMessages", "peekMessages",
"updateMessage" ], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.compon [...]
"maxMessages": { "kind": "parameter", "displayName": "Max Messages",
"group": "queue", "label": "queue", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.azure.storage.queue.QueueConfiguration",
"configurationField": "configuration", "description": "Maximum number of
messages to get, if there are less messages exist in the queue than r [...]
diff --git
a/components/camel-azure/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
b/components/camel-azure/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
index 3b9e9e0..a8e6c12 100644
---
a/components/camel-azure/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
+++
b/components/camel-azure/camel-azure-storage-queue/src/main/docs/azure-storage-queue-component.adoc
@@ -72,7 +72,7 @@ The Azure Storage Queue Service component supports 15
options, which are listed
| *configuration* (common) | The component configurations | |
QueueConfiguration
| *serviceClient* (common) | *Autowired* Service client to a storage account
to interact with the queue service. This client does not hold any state about a
particular storage account but is instead a convenient way of sending off
appropriate requests to the resource on the service. This client contains all
the operations for interacting with a queue account in Azure Storage.
Operations allowed by the client are creating, listing, and deleting queues,
retrieving and updating properties o [...]
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
-| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | true | boolean
+| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | false | boolean
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | Queue service operation hint to the producer. There
are 9 enums and the value can be one of: listQueues, createQueue, deleteQueue,
clearQueue, sendMessage, deleteMessage, receiveMessages, peekMessages,
updateMessage | | QueueOperationDefinition
| *autowiredEnabled* (advanced) | 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
@@ -119,7 +119,7 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
-| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | true | boolean
+| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | false | boolean
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | Queue service operation hint to the producer. There
are 9 enums and the value can be one of: listQueues, createQueue, deleteQueue,
clearQueue, sendMessage, deleteMessage, receiveMessages, peekMessages,
updateMessage | | QueueOperationDefinition
| *maxMessages* (queue) | Maximum number of messages to get, if there are less
messages exist in the queue than requested all the messages will be returned.
If left empty only 1 message will be retrieved, the allowed range is 1 to 32
messages. | 1 | Integer
diff --git
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConfiguration.java
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConfiguration.java
index ab9c15c..d086b12 100644
---
a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConfiguration.java
+++
b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConfiguration.java
@@ -42,8 +42,8 @@ public class QueueConfiguration implements Cloneable {
private QueueServiceClient serviceClient;
@UriParam(label = "producer")
private QueueOperationDefinition operation =
QueueOperationDefinition.sendMessage;
- @UriParam(label = "producer", defaultValue = "true")
- private boolean createQueue = true;
+ @UriParam(label = "producer", defaultValue = "false")
+ private boolean createQueue = false;
// queue properties
@UriParam(label = "queue")
private Duration timeToLive;
diff --git
a/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/integration/StorageQueueProducerIT.java
b/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/integration/StorageQueueProducerIT.java
index b10f43f..c10e7e0 100644
---
a/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/integration/StorageQueueProducerIT.java
+++
b/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/integration/StorageQueueProducerIT.java
@@ -24,11 +24,10 @@ import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.azure.storage.queue.QueueConstants;
import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.commons.lang3.RandomStringUtils;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertFalse;
class StorageQueueProducerIT extends StorageQueueBase {
@@ -65,19 +64,18 @@ class StorageQueueProducerIT extends StorageQueueBase {
@Test
public void testSendAndDeleteMessage() throws InterruptedException {
- final String queueName =
RandomStringUtils.randomAlphabetic(10).toLowerCase();
// first test if queue is not created
template.send("direct:sendMessage", ExchangePattern.InOnly, exchange
-> {
exchange.getIn().setHeader(QueueConstants.QUEUE_NAME, queueName);
exchange.getIn().setBody("test-message-1");
- exchange.getIn().setHeader(QueueConstants.CREATE_QUEUE, false);
+ exchange.getIn().setHeader(QueueConstants.CREATE_QUEUE, true);
});
result.assertIsSatisfied();
- // queue not created because of the flag
- assertTrue(result.getExchanges().isEmpty());
+ // queue is created because of the flag
+ assertFalse(result.getExchanges().isEmpty());
result.reset();
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
index ef38cdc..4663df5 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AzureStorageQueueComponentBuilderFactory.java
@@ -120,7 +120,7 @@ public interface AzureStorageQueueComponentBuilderFactory {
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: producer
*
* @param createQueue the value to set
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
index fdd8532..95e2c78 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/QueueEndpointBuilderFactory.java
@@ -1062,7 +1062,7 @@ public interface QueueEndpointBuilderFactory {
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: producer
*
* @param createQueue the value to set
@@ -1079,7 +1079,7 @@ public interface QueueEndpointBuilderFactory {
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
+ * Default: false
* Group: producer
*
* @param createQueue the value to set
diff --git
a/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
b/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
index 774eee4..93e2c69 100644
--- a/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
+++ b/docs/components/modules/ROOT/pages/azure-storage-queue-component.adoc
@@ -74,7 +74,7 @@ The Azure Storage Queue Service component supports 15
options, which are listed
| *configuration* (common) | The component configurations | |
QueueConfiguration
| *serviceClient* (common) | *Autowired* Service client to a storage account
to interact with the queue service. This client does not hold any state about a
particular storage account but is instead a convenient way of sending off
appropriate requests to the resource on the service. This client contains all
the operations for interacting with a queue account in Azure Storage.
Operations allowed by the client are creating, listing, and deleting queues,
retrieving and updating properties o [...]
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
-| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | true | boolean
+| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | false | boolean
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | Queue service operation hint to the producer. There
are 9 enums and the value can be one of: listQueues, createQueue, deleteQueue,
clearQueue, sendMessage, deleteMessage, receiveMessages, peekMessages,
updateMessage | | QueueOperationDefinition
| *autowiredEnabled* (advanced) | 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
@@ -121,7 +121,7 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
-| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | true | boolean
+| *createQueue* (producer) | When is set to true, the queue will be
automatically created when sending messages to the queue. | false | boolean
| *lazyStartProducer* (producer) | 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
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | Queue service operation hint to the producer. There
are 9 enums and the value can be one of: listQueues, createQueue, deleteQueue,
clearQueue, sendMessage, deleteMessage, receiveMessages, peekMessages,
updateMessage | | QueueOperationDefinition
| *maxMessages* (queue) | Maximum number of messages to get, if there are less
messages exist in the queue than requested all the messages will be returned.
If left empty only 1 message will be retrieved, the allowed range is 1 to 32
messages. | 1 | Integer
