This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/camel-master by this push:
new 24ac7d2 [create-pull-request] automated change
24ac7d2 is described below
commit 24ac7d2436efd121b7ab9cb371552f35cbe28e40
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Oct 8 03:32:38 2020 +0000
[create-pull-request] automated change
---
.../camel-geocoder-kafka-sink-connector.json | 6 ++++++
.../docs/camel-geocoder-kafka-sink-connector.adoc | 3 ++-
.../geocoder/CamelGeocoderSinkConnectorConfig.java | 4 ++++
.../camel-rabbitmq-kafka-sink-connector.json | 24 ++++++++++++++++++++++
.../docs/camel-rabbitmq-kafka-sink-connector.adoc | 6 +++++-
.../rabbitmq/CamelRabbitmqSinkConnectorConfig.java | 16 +++++++++++++++
.../camel-geocoder-kafka-sink-connector.adoc | 3 ++-
.../camel-rabbitmq-kafka-sink-connector.adoc | 6 +++++-
8 files changed, 64 insertions(+), 4 deletions(-)
diff --git
a/connectors/camel-geocoder-kafka-connector/src/generated/resources/camel-geocoder-kafka-sink-connector.json
b/connectors/camel-geocoder-kafka-connector/src/generated/resources/camel-geocoder-kafka-sink-connector.json
index bb97771..078f0e5 100644
---
a/connectors/camel-geocoder-kafka-connector/src/generated/resources/camel-geocoder-kafka-sink-connector.json
+++
b/connectors/camel-geocoder-kafka-connector/src/generated/resources/camel-geocoder-kafka-sink-connector.json
@@ -133,6 +133,12 @@
"description": "Whether the component should use basic
property binding (Camel 2.x) or the newer property binding with additional
capabilities",
"defaultValue": "false",
"priority": "LOW"
+ },
+ "camel.component.geocoder.geoApiContext": {
+ "name": "camel.component.geocoder.geoApiContext",
+ "description": "Configuration for Google maps API",
+ "defaultValue": "null",
+ "priority": "MEDIUM"
}
}
}
\ No newline at end of file
diff --git
a/connectors/camel-geocoder-kafka-connector/src/main/docs/camel-geocoder-kafka-sink-connector.adoc
b/connectors/camel-geocoder-kafka-connector/src/main/docs/camel-geocoder-kafka-sink-connector.adoc
index 6cd4691..4d97ee6 100644
---
a/connectors/camel-geocoder-kafka-connector/src/main/docs/camel-geocoder-kafka-sink-connector.adoc
+++
b/connectors/camel-geocoder-kafka-connector/src/main/docs/camel-geocoder-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.geocoder.CamelGeocoderSinkConnec
----
-The camel-geocoder sink connector supports 21 options, which are listed below.
+The camel-geocoder sink connector supports 22 options, which are listed below.
@@ -50,6 +50,7 @@ The camel-geocoder sink connector supports 21 options, which
are listed below.
| *camel.sink.endpoint.clientKey* | Client Key to access Google GeoCoding
server. | null | MEDIUM
| *camel.component.geocoder.lazyStartProducer* | 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 the [...]
| *camel.component.geocoder.basicPropertyBinding* | Whether the component
should use basic property binding (Camel 2.x) or the newer property binding
with additional capabilities | false | LOW
+| *camel.component.geocoder.geoApiContext* | Configuration for Google maps API
| null | MEDIUM
|===
diff --git
a/connectors/camel-geocoder-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/geocoder/CamelGeocoderSinkConnectorConfig.java
b/connectors/camel-geocoder-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/geocoder/CamelGeocoderSinkConnectorConfig.java
index a030cad..b8cf3b6 100644
---
a/connectors/camel-geocoder-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/geocoder/CamelGeocoderSinkConnectorConfig.java
+++
b/connectors/camel-geocoder-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/geocoder/CamelGeocoderSinkConnectorConfig.java
@@ -89,6 +89,9 @@ public class CamelGeocoderSinkConnectorConfig
public static final String
CAMEL_SINK_GEOCODER_COMPONENT_BASIC_PROPERTY_BINDING_CONF =
"camel.component.geocoder.basicPropertyBinding";
public static final String
CAMEL_SINK_GEOCODER_COMPONENT_BASIC_PROPERTY_BINDING_DOC = "Whether the
component should use basic property binding (Camel 2.x) or the newer property
binding with additional capabilities";
public static final Boolean
CAMEL_SINK_GEOCODER_COMPONENT_BASIC_PROPERTY_BINDING_DEFAULT = false;
+ public static final String
CAMEL_SINK_GEOCODER_COMPONENT_GEO_API_CONTEXT_CONF =
"camel.component.geocoder.geoApiContext";
+ public static final String
CAMEL_SINK_GEOCODER_COMPONENT_GEO_API_CONTEXT_DOC = "Configuration for Google
maps API";
+ public static final String
CAMEL_SINK_GEOCODER_COMPONENT_GEO_API_CONTEXT_DEFAULT = null;
public CamelGeocoderSinkConnectorConfig(
ConfigDef config,
@@ -123,6 +126,7 @@ public class CamelGeocoderSinkConnectorConfig
conf.define(CAMEL_SINK_GEOCODER_ENDPOINT_CLIENT_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GEOCODER_ENDPOINT_CLIENT_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GEOCODER_ENDPOINT_CLIENT_KEY_DOC);
conf.define(CAMEL_SINK_GEOCODER_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GEOCODER_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GEOCODER_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_GEOCODER_COMPONENT_BASIC_PROPERTY_BINDING_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GEOCODER_COMPONENT_BASIC_PROPERTY_BINDING_DEFAULT,
ConfigDef.Importance.LOW,
CAMEL_SINK_GEOCODER_COMPONENT_BASIC_PROPERTY_BINDING_DOC);
+ conf.define(CAMEL_SINK_GEOCODER_COMPONENT_GEO_API_CONTEXT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GEOCODER_COMPONENT_GEO_API_CONTEXT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GEOCODER_COMPONENT_GEO_API_CONTEXT_DOC);
return conf;
}
}
\ No newline at end of file
diff --git
a/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-kafka-sink-connector.json
b/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-kafka-sink-connector.json
index fd5f297..0308a38 100644
---
a/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-kafka-sink-connector.json
+++
b/connectors/camel-rabbitmq-kafka-connector/src/generated/resources/camel-rabbitmq-kafka-sink-connector.json
@@ -146,6 +146,18 @@
"defaultValue": "\"\/\"",
"priority": "MEDIUM"
},
+ "camel.sink.endpoint.additionalHeaders": {
+ "name": "camel.sink.endpoint.additionalHeaders",
+ "description": "Map of additional headers. These
headers will be set only when the 'allowCustomHeaders' is set to true",
+ "defaultValue": "null",
+ "priority": "MEDIUM"
+ },
+ "camel.sink.endpoint.additionalProperties": {
+ "name": "camel.sink.endpoint.additionalProperties",
+ "description": "Map of additional properties. These are
standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored.",
+ "defaultValue": "null",
+ "priority": "MEDIUM"
+ },
"camel.sink.endpoint.allowCustomHeaders": {
"name": "camel.sink.endpoint.allowCustomHeaders",
"description": "Allow pass custom values to header",
@@ -428,6 +440,18 @@
"defaultValue": "\"\/\"",
"priority": "MEDIUM"
},
+ "camel.component.rabbitmq.additionalHeaders": {
+ "name": "camel.component.rabbitmq.additionalHeaders",
+ "description": "Map of additional headers. These
headers will be set only when the 'allowCustomHeaders' is set to true",
+ "defaultValue": "null",
+ "priority": "MEDIUM"
+ },
+ "camel.component.rabbitmq.additionalProperties": {
+ "name": "camel.component.rabbitmq.additionalProperties",
+ "description": "Map of additional properties. These are
standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored. When the message already contains these headers they will be given
precedence over these properties.",
+ "defaultValue": "null",
+ "priority": "MEDIUM"
+ },
"camel.component.rabbitmq.allowNullHeaders": {
"name": "camel.component.rabbitmq.allowNullHeaders",
"description": "Allow pass null values to header",
diff --git
a/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-sink-connector.adoc
b/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-sink-connector.adoc
index 2c5b13b..41dc456 100644
---
a/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-sink-connector.adoc
+++
b/connectors/camel-rabbitmq-kafka-connector/src/main/docs/camel-rabbitmq-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSinkConnec
----
-The camel-rabbitmq sink connector supports 98 options, which are listed below.
+The camel-rabbitmq sink connector supports 102 options, which are listed below.
@@ -52,6 +52,8 @@ The camel-rabbitmq sink connector supports 98 options, which
are listed below.
| *camel.sink.endpoint.skipQueueBind* | If true the queue will not be bound to
the exchange after declaring it | false | MEDIUM
| *camel.sink.endpoint.skipQueueDeclare* | If true the producer will not
declare and bind a queue. This can be used for directing messages via an
existing routing key. | false | MEDIUM
| *camel.sink.endpoint.vhost* | The vhost for the channel | "/" | MEDIUM
+| *camel.sink.endpoint.additionalHeaders* | Map of additional headers. These
headers will be set only when the 'allowCustomHeaders' is set to true | null |
MEDIUM
+| *camel.sink.endpoint.additionalProperties* | Map of additional properties.
These are standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored. | null | MEDIUM
| *camel.sink.endpoint.allowCustomHeaders* | Allow pass custom values to
header | false | MEDIUM
| *camel.sink.endpoint.allowNullHeaders* | Allow pass null values to header |
false | MEDIUM
| *camel.sink.endpoint.bridgeEndpoint* | If the bridgeEndpoint is true, the
producer will ignore the message header of rabbitmq.EXCHANGE_NAME and
rabbitmq.ROUTING_KEY | false | MEDIUM
@@ -99,6 +101,8 @@ The camel-rabbitmq sink connector supports 98 options, which
are listed below.
| *camel.component.rabbitmq.skipQueueBind* | If true the queue will not be
bound to the exchange after declaring it | false | MEDIUM
| *camel.component.rabbitmq.skipQueueDeclare* | If true the producer will not
declare and bind a queue. This can be used for directing messages via an
existing routing key. | false | MEDIUM
| *camel.component.rabbitmq.vhost* | The vhost for the channel | "/" | MEDIUM
+| *camel.component.rabbitmq.additionalHeaders* | Map of additional headers.
These headers will be set only when the 'allowCustomHeaders' is set to true |
null | MEDIUM
+| *camel.component.rabbitmq.additionalProperties* | Map of additional
properties. These are standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored. When the message already contains these headers they will be given
precedence over these properties. | null | MEDIUM
| *camel.component.rabbitmq.allowNullHeaders* | Allow pass null values to
header | false | MEDIUM
| *camel.component.rabbitmq.channelPoolMaxSize* | Get maximum number of opened
channel in pool | 10 | MEDIUM
| *camel.component.rabbitmq.channelPoolMaxWait* | Set the maximum number of
milliseconds to wait for a channel from the pool | 1000L | MEDIUM
diff --git
a/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSinkConnectorConfig.java
b/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSinkConnectorConfig.java
index 4919a7e..09f3457 100644
---
a/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSinkConnectorConfig.java
+++
b/connectors/camel-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmq/CamelRabbitmqSinkConnectorConfig.java
@@ -95,6 +95,12 @@ public class CamelRabbitmqSinkConnectorConfig
public static final String CAMEL_SINK_RABBITMQ_ENDPOINT_VHOST_CONF =
"camel.sink.endpoint.vhost";
public static final String CAMEL_SINK_RABBITMQ_ENDPOINT_VHOST_DOC = "The
vhost for the channel";
public static final String CAMEL_SINK_RABBITMQ_ENDPOINT_VHOST_DEFAULT =
"/";
+ public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_HEADERS_CONF =
"camel.sink.endpoint.additionalHeaders";
+ public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_HEADERS_DOC = "Map of additional
headers. These headers will be set only when the 'allowCustomHeaders' is set to
true";
+ public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_HEADERS_DEFAULT = null;
+ public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_PROPERTIES_CONF =
"camel.sink.endpoint.additionalProperties";
+ public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_PROPERTIES_DOC = "Map of additional
properties. These are standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored.";
+ public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_PROPERTIES_DEFAULT = null;
public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_CUSTOM_HEADERS_CONF =
"camel.sink.endpoint.allowCustomHeaders";
public static final String
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_CUSTOM_HEADERS_DOC = "Allow pass custom
values to header";
public static final Boolean
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_CUSTOM_HEADERS_DEFAULT = false;
@@ -236,6 +242,12 @@ public class CamelRabbitmqSinkConnectorConfig
public static final String CAMEL_SINK_RABBITMQ_COMPONENT_VHOST_CONF =
"camel.component.rabbitmq.vhost";
public static final String CAMEL_SINK_RABBITMQ_COMPONENT_VHOST_DOC = "The
vhost for the channel";
public static final String CAMEL_SINK_RABBITMQ_COMPONENT_VHOST_DEFAULT =
"/";
+ public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_HEADERS_CONF =
"camel.component.rabbitmq.additionalHeaders";
+ public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_HEADERS_DOC = "Map of additional
headers. These headers will be set only when the 'allowCustomHeaders' is set to
true";
+ public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_HEADERS_DEFAULT = null;
+ public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_PROPERTIES_CONF =
"camel.component.rabbitmq.additionalProperties";
+ public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_PROPERTIES_DOC = "Map of additional
properties. These are standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored. When the message already contains these headers they will be given
precedence over these properties.";
+ public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_PROPERTIES_DEFAULT = null;
public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ALLOW_NULL_HEADERS_CONF =
"camel.component.rabbitmq.allowNullHeaders";
public static final String
CAMEL_SINK_RABBITMQ_COMPONENT_ALLOW_NULL_HEADERS_DOC = "Allow pass null values
to header";
public static final Boolean
CAMEL_SINK_RABBITMQ_COMPONENT_ALLOW_NULL_HEADERS_DEFAULT = false;
@@ -356,6 +368,8 @@ public class CamelRabbitmqSinkConnectorConfig
conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_SKIP_QUEUE_BIND_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_RABBITMQ_ENDPOINT_SKIP_QUEUE_BIND_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_RABBITMQ_ENDPOINT_SKIP_QUEUE_BIND_DOC);
conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_SKIP_QUEUE_DECLARE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_RABBITMQ_ENDPOINT_SKIP_QUEUE_DECLARE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_ENDPOINT_SKIP_QUEUE_DECLARE_DOC);
conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_VHOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_RABBITMQ_ENDPOINT_VHOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_RABBITMQ_ENDPOINT_VHOST_DOC);
+ conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_HEADERS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_HEADERS_DOC);
+ conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_PROPERTIES_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_PROPERTIES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_ENDPOINT_ADDITIONAL_PROPERTIES_DOC);
conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_CUSTOM_HEADERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_CUSTOM_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_CUSTOM_HEADERS_DOC);
conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_NULL_HEADERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_NULL_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_ENDPOINT_ALLOW_NULL_HEADERS_DOC);
conf.define(CAMEL_SINK_RABBITMQ_ENDPOINT_BRIDGE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_RABBITMQ_ENDPOINT_BRIDGE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_RABBITMQ_ENDPOINT_BRIDGE_ENDPOINT_DOC);
@@ -403,6 +417,8 @@ public class CamelRabbitmqSinkConnectorConfig
conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_SKIP_QUEUE_BIND_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_RABBITMQ_COMPONENT_SKIP_QUEUE_BIND_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_RABBITMQ_COMPONENT_SKIP_QUEUE_BIND_DOC);
conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_SKIP_QUEUE_DECLARE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_RABBITMQ_COMPONENT_SKIP_QUEUE_DECLARE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_COMPONENT_SKIP_QUEUE_DECLARE_DOC);
conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_VHOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_RABBITMQ_COMPONENT_VHOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_RABBITMQ_COMPONENT_VHOST_DOC);
+ conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_HEADERS_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_HEADERS_DOC);
+ conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_PROPERTIES_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_PROPERTIES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_COMPONENT_ADDITIONAL_PROPERTIES_DOC);
conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_ALLOW_NULL_HEADERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_RABBITMQ_COMPONENT_ALLOW_NULL_HEADERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_COMPONENT_ALLOW_NULL_HEADERS_DOC);
conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_CHANNEL_POOL_MAX_SIZE_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_RABBITMQ_COMPONENT_CHANNEL_POOL_MAX_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_COMPONENT_CHANNEL_POOL_MAX_SIZE_DOC);
conf.define(CAMEL_SINK_RABBITMQ_COMPONENT_CHANNEL_POOL_MAX_WAIT_CONF,
ConfigDef.Type.LONG,
CAMEL_SINK_RABBITMQ_COMPONENT_CHANNEL_POOL_MAX_WAIT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_RABBITMQ_COMPONENT_CHANNEL_POOL_MAX_WAIT_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-geocoder-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-geocoder-kafka-sink-connector.adoc
index 6cd4691..4d97ee6 100644
---
a/docs/modules/ROOT/pages/connectors/camel-geocoder-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-geocoder-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.geocoder.CamelGeocoderSinkConnec
----
-The camel-geocoder sink connector supports 21 options, which are listed below.
+The camel-geocoder sink connector supports 22 options, which are listed below.
@@ -50,6 +50,7 @@ The camel-geocoder sink connector supports 21 options, which
are listed below.
| *camel.sink.endpoint.clientKey* | Client Key to access Google GeoCoding
server. | null | MEDIUM
| *camel.component.geocoder.lazyStartProducer* | 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 the [...]
| *camel.component.geocoder.basicPropertyBinding* | Whether the component
should use basic property binding (Camel 2.x) or the newer property binding
with additional capabilities | false | LOW
+| *camel.component.geocoder.geoApiContext* | Configuration for Google maps API
| null | MEDIUM
|===
diff --git
a/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-sink-connector.adoc
index 2c5b13b..41dc456 100644
---
a/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-rabbitmq-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSinkConnec
----
-The camel-rabbitmq sink connector supports 98 options, which are listed below.
+The camel-rabbitmq sink connector supports 102 options, which are listed below.
@@ -52,6 +52,8 @@ The camel-rabbitmq sink connector supports 98 options, which
are listed below.
| *camel.sink.endpoint.skipQueueBind* | If true the queue will not be bound to
the exchange after declaring it | false | MEDIUM
| *camel.sink.endpoint.skipQueueDeclare* | If true the producer will not
declare and bind a queue. This can be used for directing messages via an
existing routing key. | false | MEDIUM
| *camel.sink.endpoint.vhost* | The vhost for the channel | "/" | MEDIUM
+| *camel.sink.endpoint.additionalHeaders* | Map of additional headers. These
headers will be set only when the 'allowCustomHeaders' is set to true | null |
MEDIUM
+| *camel.sink.endpoint.additionalProperties* | Map of additional properties.
These are standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored. | null | MEDIUM
| *camel.sink.endpoint.allowCustomHeaders* | Allow pass custom values to
header | false | MEDIUM
| *camel.sink.endpoint.allowNullHeaders* | Allow pass null values to header |
false | MEDIUM
| *camel.sink.endpoint.bridgeEndpoint* | If the bridgeEndpoint is true, the
producer will ignore the message header of rabbitmq.EXCHANGE_NAME and
rabbitmq.ROUTING_KEY | false | MEDIUM
@@ -99,6 +101,8 @@ The camel-rabbitmq sink connector supports 98 options, which
are listed below.
| *camel.component.rabbitmq.skipQueueBind* | If true the queue will not be
bound to the exchange after declaring it | false | MEDIUM
| *camel.component.rabbitmq.skipQueueDeclare* | If true the producer will not
declare and bind a queue. This can be used for directing messages via an
existing routing key. | false | MEDIUM
| *camel.component.rabbitmq.vhost* | The vhost for the channel | "/" | MEDIUM
+| *camel.component.rabbitmq.additionalHeaders* | Map of additional headers.
These headers will be set only when the 'allowCustomHeaders' is set to true |
null | MEDIUM
+| *camel.component.rabbitmq.additionalProperties* | Map of additional
properties. These are standard RabbitMQ properties as defined in
com.rabbitmq.client.AMQP.BasicProperties The map keys should be from
org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be
ignored. When the message already contains these headers they will be given
precedence over these properties. | null | MEDIUM
| *camel.component.rabbitmq.allowNullHeaders* | Allow pass null values to
header | false | MEDIUM
| *camel.component.rabbitmq.channelPoolMaxSize* | Get maximum number of opened
channel in pool | 10 | MEDIUM
| *camel.component.rabbitmq.channelPoolMaxWait* | Set the maximum number of
milliseconds to wait for a channel from the pool | 1000L | MEDIUM
