This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 87afa9bec5b Regen
87afa9bec5b is described below
commit 87afa9bec5b79d466ce29b2cf96530a17b058e1a
Author: Claus Ibsen <[email protected]>
AuthorDate: Tue Feb 20 14:39:05 2024 +0100
Regen
---
.../springboot/catalog/components/spring-rabbitmq.json | 11 ++++++-----
.../src/main/docs/spring-rabbitmq.json | 6 ++++++
.../springboot/SpringRabbitMQComponentConfiguration.java | 16 ++++++++++++++++
3 files changed, 28 insertions(+), 5 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
index 3cc17590684..1757964919b 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
@@ -47,11 +47,12 @@
"allowNullBody": { "index": 21, "kind": "property", "displayName": "Allow
Null Body", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to allow
sending messages with no body. If this option is false and the message body is
null, then an MessageConversionException is thrown." },
"lazyStartProducer": { "index": 22, "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 fai [...]
"replyTimeout": { "index": 23, "kind": "property", "displayName": "Reply
Timeout", "group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5000", "description": "Specify the timeout in
milliseconds to be used when waiting for a reply message when doing
request\/reply messaging. The default value is 5 seconds. A negative value
indicates an indefinite timeout." },
- "autowiredEnabled": { "index": 24, "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 [...]
- "ignoreDeclarationExceptions": { "index": 25, "kind": "property",
"displayName": "Ignore Declaration Exceptions", "group": "advanced", "label":
"advanced", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "Switch on ignore exceptions such as mismatched
properties when declaring" },
- "messageConverter": { "index": 26, "kind": "property", "displayName":
"Message Converter", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.springframework.amqp.support.converter.MessageConverter", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
MessageConverter so you can be in control how to map to\/from a
org.springframework.amqp.core.Message." },
- "messagePropertiesConverter": { "index": 27, "kind": "property",
"displayName": "Message Properties Converter", "group": "advanced", "label":
"advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.springrabbit.MessagePropertiesConverter",
"deprecated": false, "autowired": false, "secret": false, "description": "To
use a custom MessagePropertiesConverter so you can be in control how to map
to\/from a org.springframework.amqp.core.MessageProperties." },
- "headerFilterStrategy": { "index": 28, "kind": "property", "displayName":
"Header Filter Strategy", "group": "filter", "label": "filter", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom
org.apache.camel.spi.HeaderFilterStrategy to filter header to and from Camel
message." }
+ "args": { "index": 24, "kind": "property", "displayName": "Args", "group":
"advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "java.util.Map<java.lang.String, java.lang.Object>", "deprecated":
false, "autowired": false, "secret": false, "description": "Specify arguments
for configuring the different RabbitMQ concepts, a different prefix is required
for each element: consumer. exchange. queue. binding. dlq.exchange. dlq.queue.
dlq.binding. For example to [...]
+ "autowiredEnabled": { "index": 25, "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 [...]
+ "ignoreDeclarationExceptions": { "index": 26, "kind": "property",
"displayName": "Ignore Declaration Exceptions", "group": "advanced", "label":
"advanced", "required": false, "type": "boolean", "javaType": "boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "Switch on ignore exceptions such as mismatched
properties when declaring" },
+ "messageConverter": { "index": 27, "kind": "property", "displayName":
"Message Converter", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.springframework.amqp.support.converter.MessageConverter", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
MessageConverter so you can be in control how to map to\/from a
org.springframework.amqp.core.Message." },
+ "messagePropertiesConverter": { "index": 28, "kind": "property",
"displayName": "Message Properties Converter", "group": "advanced", "label":
"advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.springrabbit.MessagePropertiesConverter",
"deprecated": false, "autowired": false, "secret": false, "description": "To
use a custom MessagePropertiesConverter so you can be in control how to map
to\/from a org.springframework.amqp.core.MessageProperties." },
+ "headerFilterStrategy": { "index": 29, "kind": "property", "displayName":
"Header Filter Strategy", "group": "filter", "label": "filter", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom
org.apache.camel.spi.HeaderFilterStrategy to filter header to and from Camel
message." }
},
"headers": {
"CamelSpringRabbitmqRoutingOverrideKey": { "index": 0, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "To override the endpoint
configuration's routing key.", "constantName":
"org.apache.camel.component.springrabbit.SpringRabbitMQConstants#ROUTING_OVERRIDE_KEY"
},
diff --git
a/components-starter/camel-spring-rabbitmq-starter/src/main/docs/spring-rabbitmq.json
b/components-starter/camel-spring-rabbitmq-starter/src/main/docs/spring-rabbitmq.json
index db76d282ec5..a821ea742e4 100644
---
a/components-starter/camel-spring-rabbitmq-starter/src/main/docs/spring-rabbitmq.json
+++
b/components-starter/camel-spring-rabbitmq-starter/src/main/docs/spring-rabbitmq.json
@@ -26,6 +26,12 @@
"description": "Optional AMQP Admin service to use for auto declaring
elements (queues, exchanges, bindings). The option is a
org.springframework.amqp.core.AmqpAdmin type.",
"sourceType":
"org.apache.camel.component.springrabbit.springboot.SpringRabbitMQComponentConfiguration"
},
+ {
+ "name": "camel.component.spring-rabbitmq.args",
+ "type": "java.util.Map<java.lang.String,java.lang.Object>",
+ "description": "Specify arguments for configuring the different RabbitMQ
concepts, a different prefix is required for each element: consumer. exchange.
queue. binding. dlq.exchange. dlq.queue. dlq.binding. For example to declare a
queue with message ttl argument: queue.x-message-ttl=60000",
+ "sourceType":
"org.apache.camel.component.springrabbit.springboot.SpringRabbitMQComponentConfiguration"
+ },
{
"name": "camel.component.spring-rabbitmq.auto-declare",
"type": "java.lang.Boolean",
diff --git
a/components-starter/camel-spring-rabbitmq-starter/src/main/java/org/apache/camel/component/springrabbit/springboot/SpringRabbitMQComponentConfiguration.java
b/components-starter/camel-spring-rabbitmq-starter/src/main/java/org/apache/camel/component/springrabbit/springboot/SpringRabbitMQComponentConfiguration.java
index b82b44f48ef..4ce6bcbe0b5 100644
---
a/components-starter/camel-spring-rabbitmq-starter/src/main/java/org/apache/camel/component/springrabbit/springboot/SpringRabbitMQComponentConfiguration.java
+++
b/components-starter/camel-spring-rabbitmq-starter/src/main/java/org/apache/camel/component/springrabbit/springboot/SpringRabbitMQComponentConfiguration.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.springrabbit.springboot;
+import java.util.Map;
import org.apache.camel.component.springrabbit.ListenerContainerFactory;
import org.apache.camel.component.springrabbit.MessagePropertiesConverter;
import org.apache.camel.spi.HeaderFilterStrategy;
@@ -186,6 +187,13 @@ public class SpringRabbitMQComponentConfiguration
* a long type.
*/
private Long replyTimeout = 5000L;
+ /**
+ * Specify arguments for configuring the different RabbitMQ concepts, a
+ * different prefix is required for each element: consumer. exchange.
queue.
+ * binding. dlq.exchange. dlq.queue. dlq.binding. For example to declare a
+ * queue with message ttl argument: queue.x-message-ttl=60000
+ */
+ private Map<String, Object> args;
/**
* Whether autowiring is enabled. This is used for automatic autowiring
* options (the option must be marked as autowired) by looking up in the
@@ -413,6 +421,14 @@ public class SpringRabbitMQComponentConfiguration
this.replyTimeout = replyTimeout;
}
+ public Map<String, Object> getArgs() {
+ return args;
+ }
+
+ public void setArgs(Map<String, Object> args) {
+ this.args = args;
+ }
+
public Boolean getAutowiredEnabled() {
return autowiredEnabled;
}
