This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new e40adec CAMEL-16589: Fix PEEK_LOCK typo in the servicebus config
e40adec is described below
commit e40adeccf08356c623997b4ce3705f3e1d44d5fb
Author: Omar Al-Safi <omars...@gmail.com>
AuthorDate: Tue Jul 6 11:06:12 2021 +0200
CAMEL-16589: Fix PEEK_LOCK typo in the servicebus config
---
.../org/apache/camel/component/azure/servicebus/azure-servicebus.json | 4 ++--
.../src/main/docs/azure-servicebus-component.adoc | 4 ++--
.../camel/component/azure/servicebus/ServiceBusConfiguration.java | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
b/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
index 1a96c0e..e82b699 100644
---
a/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
+++
b/components/camel-azure/camel-azure-servicebus/src/generated/resources/org/apache/camel/component/azure/servicebus/azure-servicebus.json
@@ -35,7 +35,7 @@
"peekNumMaxMessages": { "kind": "property", "displayName": "Peek Num Max
Messages", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Set the max number of
messages to be peeked during the peek operation." },
"prefetchCount": { "kind": "property", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK [...]
"receiverAsyncClient": { "kind": "property", "displayName": "Receiver
Async Client", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the receiverAsy
[...]
- "serviceBusReceiveMode": { "kind": "property", "displayName": "Service Bus
Receive Mode", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEER_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationFie [...]
+ "serviceBusReceiveMode": { "kind": "property", "displayName": "Service Bus
Receive Mode", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEEK_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationFie [...]
"subQueue": { "kind": "property", "displayName": "Sub Queue", "group":
"consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "com.azure.messaging.servicebus.models.SubQueue", "enum": [ "NONE",
"DEAD_LETTER_QUEUE", "TRANSFER_DEAD_LETTER_QUEUE" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the [...]
"subscriptionName": { "kind": "property", "displayName": "Subscription
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
subscription in the topic to listen to. topicOrQueueName and serviceBusT [...]
"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 [...]
@@ -60,7 +60,7 @@
"peekNumMaxMessages": { "kind": "parameter", "displayName": "Peek Num Max
Messages", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Set the max number of
messages to be peeked during the peek operation." },
"prefetchCount": { "kind": "parameter", "displayName": "Prefetch Count",
"group": "consumer", "label": "consumer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 0, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEE [...]
"receiverAsyncClient": { "kind": "parameter", "displayName": "Receiver
Async Client", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the receiverAs [...]
- "serviceBusReceiveMode": { "kind": "parameter", "displayName": "Service
Bus Receive Mode", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEER_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationFi [...]
+ "serviceBusReceiveMode": { "kind": "parameter", "displayName": "Service
Bus Receive Mode", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"com.azure.messaging.servicebus.models.ServiceBusReceiveMode", "enum": [
"PEEK_LOCK", "RECEIVE_AND_DELETE" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "PEEK_LOCK", "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationFi [...]
"subQueue": { "kind": "parameter", "displayName": "Sub Queue", "group":
"consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "com.azure.messaging.servicebus.models.SubQueue", "enum": [ "NONE",
"DEAD_LETTER_QUEUE", "TRANSFER_DEAD_LETTER_QUEUE" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets th [...]
"subscriptionName": { "kind": "parameter", "displayName": "Subscription
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.servicebus.ServiceBusConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
subscription in the topic to listen to. topicOrQueueName and serviceBus [...]
"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 [...]
diff --git
a/components/camel-azure/camel-azure-servicebus/src/main/docs/azure-servicebus-component.adoc
b/components/camel-azure/camel-azure-servicebus/src/main/docs/azure-servicebus-component.adoc
index cc225e8..2c3f43c 100644
---
a/components/camel-azure/camel-azure-servicebus/src/main/docs/azure-servicebus-component.adoc
+++
b/components/camel-azure/camel-azure-servicebus/src/main/docs/azure-servicebus-component.adoc
@@ -71,7 +71,7 @@ with the following path and query parameters:
| *peekNumMaxMessages* (consumer) | Set the max number of messages to be
peeked during the peek operation. | | Integer
| *prefetchCount* (consumer) | Sets the prefetch count of the receiver. For
both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and {link
ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} modes the default
value is 1. Prefetch speeds up the message flow by aiming to have a message
readily available for local retrieval when and before the application asks for
one using ServiceBusReceiverAsyncClient#receiveMessages(). Setting a non-zero
value will prefetch that number of messa [...]
| *receiverAsyncClient* (consumer) | *Autowired* Sets the receiverAsyncClient
in order to consume messages in the Consumer | | ServiceBusReceiverAsyncClient
-| *serviceBusReceiveMode* (consumer) | Sets the receive mode for the receiver.
There are 2 enums and the value can be one of: PEEK_LOCK, RECEIVE_AND_DELETE |
PEER_LOCK | ServiceBusReceiveMode
+| *serviceBusReceiveMode* (consumer) | Sets the receive mode for the receiver.
There are 2 enums and the value can be one of: PEEK_LOCK, RECEIVE_AND_DELETE |
PEEK_LOCK | ServiceBusReceiveMode
| *subQueue* (consumer) | Sets the type of the SubQueue to connect to. There
are 3 enums and the value can be one of: NONE, DEAD_LETTER_QUEUE,
TRANSFER_DEAD_LETTER_QUEUE | | SubQueue
| *subscriptionName* (consumer) | Sets the name of the subscription in the
topic to listen to. topicOrQueueName and serviceBusType=topic must also be set.
| | String
| *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
@@ -107,7 +107,7 @@ The Azure ServiceBus component supports 23 options, which
are listed below.
| *peekNumMaxMessages* (consumer) | Set the max number of messages to be
peeked during the peek operation. | | Integer
| *prefetchCount* (consumer) | Sets the prefetch count of the receiver. For
both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and {link
ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} modes the default
value is 1. Prefetch speeds up the message flow by aiming to have a message
readily available for local retrieval when and before the application asks for
one using ServiceBusReceiverAsyncClient#receiveMessages(). Setting a non-zero
value will prefetch that number of messa [...]
| *receiverAsyncClient* (consumer) | *Autowired* Sets the receiverAsyncClient
in order to consume messages in the Consumer | | ServiceBusReceiverAsyncClient
-| *serviceBusReceiveMode* (consumer) | Sets the receive mode for the receiver.
There are 2 enums and the value can be one of: PEEK_LOCK, RECEIVE_AND_DELETE |
PEER_LOCK | ServiceBusReceiveMode
+| *serviceBusReceiveMode* (consumer) | Sets the receive mode for the receiver.
There are 2 enums and the value can be one of: PEEK_LOCK, RECEIVE_AND_DELETE |
PEEK_LOCK | ServiceBusReceiveMode
| *subQueue* (consumer) | Sets the type of the SubQueue to connect to. There
are 3 enums and the value can be one of: NONE, DEAD_LETTER_QUEUE,
TRANSFER_DEAD_LETTER_QUEUE | | SubQueue
| *subscriptionName* (consumer) | Sets the name of the subscription in the
topic to listen to. topicOrQueueName and serviceBusType=topic must also be set.
| | String
| *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 [...]
diff --git
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
index 3d5ae81..b8de28c 100644
---
a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
+++
b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusConfiguration.java
@@ -63,7 +63,7 @@ public class ServiceBusConfiguration implements Cloneable {
private String subscriptionName;
@UriParam(label = "consumer", defaultValue = "false")
private boolean disableAutoComplete;
- @UriParam(label = "consumer", defaultValue = "PEER_LOCK")
+ @UriParam(label = "consumer", defaultValue = "PEEK_LOCK")
private ServiceBusReceiveMode serviceBusReceiveMode =
ServiceBusReceiveMode.PEEK_LOCK;
@UriParam(label = "consumer", defaultValue = "5min")
private Duration maxAutoLockRenewDuration = Duration.ofMinutes(5);
