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 2024/02/14 13:18:23 UTC
(camel-kamelets) branch main updated (d95bd15f -> 030bd167)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from d95bd15f Snowflake Source Kamelet: Database name could be optional since in the query you can use IDENTIFIER
new f67c7abd Added Spring-RabbitMQ Source Kamelet
new ff0c2aaf Added Spring-RabbitMQ Source Kamelet
new 6872f70e Added Spring-RabbitMQ Source Kamelet
new 7415e939 Added Spring-RabbitMQ Source Kamelet
new 3055de90 Added Spring-RabbitMQ Sink Kamelet
new a4161d84 Added Spring-RabbitMQ Sink Kamelet
new 4621ff00 Added Spring-RabbitMQ Sink and Source Kamelet
new 030bd167 Added Spring-RabbitMQ Sink and Source Kamelet
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/modules/ROOT/nav.adoc | 2 +
kamelets/spring-rabbitmq-sink.kamelet.yaml | 97 ++++++++++++++++++++
kamelets/spring-rabbitmq-source.kamelet.yaml | 102 +++++++++++++++++++++
.../kamelets/spring-rabbitmq-sink.kamelet.yaml | 97 ++++++++++++++++++++
.../kamelets/spring-rabbitmq-source.kamelet.yaml | 102 +++++++++++++++++++++
5 files changed, 400 insertions(+)
create mode 100644 kamelets/spring-rabbitmq-sink.kamelet.yaml
create mode 100644 kamelets/spring-rabbitmq-source.kamelet.yaml
create mode 100644 library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
create mode 100644 library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
(camel-kamelets) 04/08: Added Spring-RabbitMQ Source Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7415e93923f8241b7c967202defec92d7f746bd8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:05:56 2024 +0100
Added Spring-RabbitMQ Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
index b0af2831..78c94e4c 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -14,7 +14,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1alpha1
+apiVersion: camel.apache.org/v1
kind: Kamelet
metadata:
name: spring-rabbitmq-source
(camel-kamelets) 01/08: Added Spring-RabbitMQ Source Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit f67c7abd84572c18044d5a6f74f48dfcd7b87a54
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:03:48 2024 +0100
Added Spring-RabbitMQ Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/spring-rabbitmq-source.kamelet.yaml | 101 +++++++++++++++++++++++++++
1 file changed, 101 insertions(+)
diff --git a/kamelets/spring-rabbitmq-source.kamelet.yaml b/kamelets/spring-rabbitmq-source.kamelet.yaml
new file mode 100644
index 00000000..b0af2831
--- /dev/null
+++ b/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -0,0 +1,101 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: spring-rabbitmq-source
+ annotations:
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/catalog.version: "4.4.0-SNAPSHOT"
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjcxcHgiIGhlaWdodD0iMjcxcHgiIHZpZXdCb3g9Ii03LjUgMCAyNzEgMjcxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHByZXNlcnZlQXNwZWN0UmF0aW89InhNaWRZTWlkIj48cGF0aCBkPSJNMjQ1LjQ0IDEwOC4zMDhoLTg1LjA5YTcuNzM4IDcuNzM4IDAgMCAxLTcuNzM1LTcuNzM0di04OC42OEMxNTIuNjE1IDUuMzI3IDE0Ny4yOSAwIDE0MC43MjYgMGgtMzAuMzc1Yy02LjU2OCAwLTExLjg5IDUuMzI3LTExLjg5IDExLjg5NHY4OC4xNDNjMCA0LjU3My0zLjY5NyA4LjI5LTguMjcgOC4zMWwtMjcuODg1LjEzM2MtNC42MT [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/kamelet.group: "RabbitMQ"
+ camel.apache.org/kamelet.namespace: "Messaging"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+spec:
+ definition:
+ title: "RabbitMQ Source"
+ description: |-
+ Receive data from a RabbitMQ Broker.
+ required:
+ - addresses
+ - exchangeName
+ type: object
+ properties:
+ host:
+ title: Server Address
+ description: RabbitMQ broker address
+ type: string
+ example: "localhost"
+ port:
+ title: Server Port
+ description: RabbitMQ broker port
+ type: int
+ example: 5672
+ routingKey:
+ title: Routing Key
+ description: The routing key to use when binding a consumer queue to the exchange
+ type: string
+ username:
+ title: Username
+ description: The username to access the RabbitMQ server
+ type: string
+ x-descriptors:
+ - urn:camel:group:credentials
+ password:
+ title: Password
+ description: The password to access the RabbitMQ server
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ exchangeName:
+ title: Exchange name
+ description: The exchange name determines the exchange the queue will be bound to
+ type: string
+ queues:
+ title: Queue name
+ description: The queue to receive messages from
+ type: string
+ autoDeclare:
+ title: Auto Declare
+ description: The routing key to use when binding a consumer queue to the exchange
+ type: boolean
+ default: false
+ dependencies:
+ - "camel:spring-rabbitmq"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: connectionFactory
+ type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
+ properties:
+ username: '{{username}}'
+ password: '{{password}}'
+ host: '{{host}}'
+ port: '{{port}}'
+ from:
+ uri: "spring-rabbitmq://{{exchangeName}}"
+ parameters:
+ connectionFactory: "#bean:{{connectionFactory}}"
+ routingKey: "{{?routingKey}}"
+ queues: "{{?queue}}"
+ autoDeclare: "{{autoDeclare}}"
+ steps:
+ - to: "kamelet:sink"
(camel-kamelets) 03/08: Added Spring-RabbitMQ Source Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 6872f70e7e3064e04a303cbffbbfac49c274d386
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:05:09 2024 +0100
Added Spring-RabbitMQ Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/spring-rabbitmq-source.kamelet.yaml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/kamelets/spring-rabbitmq-source.kamelet.yaml b/kamelets/spring-rabbitmq-source.kamelet.yaml
index b0af2831..78c94e4c 100644
--- a/kamelets/spring-rabbitmq-source.kamelet.yaml
+++ b/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -14,7 +14,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
# ---------------------------------------------------------------------------
-apiVersion: camel.apache.org/v1alpha1
+apiVersion: camel.apache.org/v1
kind: Kamelet
metadata:
name: spring-rabbitmq-source
(camel-kamelets) 08/08: Added Spring-RabbitMQ Sink and Source Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 030bd167b8d380af1960bc237c7c10ca4c9ca127
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:13:22 2024 +0100
Added Spring-RabbitMQ Sink and Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/spring-rabbitmq-sink.kamelet.yaml | 2 +-
kamelets/spring-rabbitmq-source.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml | 2 +-
.../src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/kamelets/spring-rabbitmq-sink.kamelet.yaml b/kamelets/spring-rabbitmq-sink.kamelet.yaml
index d2cf135d..77d1f8c3 100644
--- a/kamelets/spring-rabbitmq-sink.kamelet.yaml
+++ b/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -94,4 +94,4 @@ spec:
parameters:
connectionFactory: "#bean:{{connectionFactory}}"
routingKey: "{{?routingKey}}"
- queues: "{{?queue}}"
+ queues: "{{?queues}}"
diff --git a/kamelets/spring-rabbitmq-source.kamelet.yaml b/kamelets/spring-rabbitmq-source.kamelet.yaml
index c4101166..d96e2b37 100644
--- a/kamelets/spring-rabbitmq-source.kamelet.yaml
+++ b/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -96,7 +96,7 @@ spec:
parameters:
connectionFactory: "#bean:{{connectionFactory}}"
routingKey: "{{?routingKey}}"
- queues: "{{?queue}}"
+ queues: "{{?queues}}"
autoDeclare: "{{autoDeclare}}"
steps:
- to: "kamelet:sink"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
index d2cf135d..77d1f8c3 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -94,4 +94,4 @@ spec:
parameters:
connectionFactory: "#bean:{{connectionFactory}}"
routingKey: "{{?routingKey}}"
- queues: "{{?queue}}"
+ queues: "{{?queues}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
index c4101166..d96e2b37 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -96,7 +96,7 @@ spec:
parameters:
connectionFactory: "#bean:{{connectionFactory}}"
routingKey: "{{?routingKey}}"
- queues: "{{?queue}}"
+ queues: "{{?queues}}"
autoDeclare: "{{autoDeclare}}"
steps:
- to: "kamelet:sink"
(camel-kamelets) 06/08: Added Spring-RabbitMQ Sink Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a4161d84d8edcafd171b41bc7b0cbfcab288b69c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:07:38 2024 +0100
Added Spring-RabbitMQ Sink Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kamelets/spring-rabbitmq-sink.kamelet.yaml | 96 ++++++++++++++++++++++
1 file changed, 96 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
new file mode 100644
index 00000000..1c0b3ef2
--- /dev/null
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -0,0 +1,96 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+apiVersion: camel.apache.org/v1
+kind: Kamelet
+metadata:
+ name: spring-rabbitmq-sink
+ annotations:
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/catalog.version: "4.4.0-SNAPSHOT"
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjcxcHgiIGhlaWdodD0iMjcxcHgiIHZpZXdCb3g9Ii03LjUgMCAyNzEgMjcxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHByZXNlcnZlQXNwZWN0UmF0aW89InhNaWRZTWlkIj48cGF0aCBkPSJNMjQ1LjQ0IDEwOC4zMDhoLTg1LjA5YTcuNzM4IDcuNzM4IDAgMCAxLTcuNzM1LTcuNzM0di04OC42OEMxNTIuNjE1IDUuMzI3IDE0Ny4yOSAwIDE0MC43MjYgMGgtMzAuMzc1Yy02LjU2OCAwLTExLjg5IDUuMzI3LTExLjg5IDExLjg5NHY4OC4xNDNjMCA0LjU3My0zLjY5NyA4LjI5LTguMjcgOC4zMWwtMjcuODg1LjEzM2MtNC42MT [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/kamelet.group: "RabbitMQ"
+ camel.apache.org/kamelet.namespace: "Messaging"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+spec:
+ definition:
+ title: "RabbitMQ Sink"
+ description: |-
+ Send data to a RabbitMQ Broker.
+ required:
+ - addresses
+ - exchangeName
+ type: object
+ properties:
+ host:
+ title: Server Address
+ description: RabbitMQ broker address
+ type: string
+ example: "localhost"
+ port:
+ title: Server Port
+ description: RabbitMQ broker port
+ type: int
+ example: 5672
+ routingKey:
+ title: Routing Key
+ description: The routing key to use when binding a consumer queue to the exchange
+ type: string
+ username:
+ title: Username
+ description: The username to access the RabbitMQ server
+ type: string
+ x-descriptors:
+ - urn:camel:group:credentials
+ password:
+ title: Password
+ description: The password to access the RabbitMQ server
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ exchangeName:
+ title: Exchange name
+ description: The exchange name determines the exchange the queue will be bound to
+ type: string
+ queues:
+ title: Queue name
+ description: The queue to receive messages from
+ type: string
+ dependencies:
+ - "camel:spring-rabbitmq"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: connectionFactory
+ type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
+ properties:
+ username: '{{username}}'
+ password: '{{password}}'
+ host: '{{host}}'
+ port: '{{port}}'
+ from:
+ uri: "kamelet:source"
+ steps:
+ - to:
+ uri: "spring-rabbitmq://{{exchangeName}}"
+ parameters:
+ connectionFactory: "#bean:{{connectionFactory}}"
+ routingKey: "{{?routingKey}}"
+ queues: "{{?queue}}"
(camel-kamelets) 02/08: Added Spring-RabbitMQ Source Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ff0c2aaf028cc08b82bb3a2e03e7992331fc5ecd
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:04:29 2024 +0100
Added Spring-RabbitMQ Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kamelets/spring-rabbitmq-source.kamelet.yaml | 101 +++++++++++++++++++++
1 file changed, 101 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
new file mode 100644
index 00000000..b0af2831
--- /dev/null
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -0,0 +1,101 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: spring-rabbitmq-source
+ annotations:
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/catalog.version: "4.4.0-SNAPSHOT"
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjcxcHgiIGhlaWdodD0iMjcxcHgiIHZpZXdCb3g9Ii03LjUgMCAyNzEgMjcxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHByZXNlcnZlQXNwZWN0UmF0aW89InhNaWRZTWlkIj48cGF0aCBkPSJNMjQ1LjQ0IDEwOC4zMDhoLTg1LjA5YTcuNzM4IDcuNzM4IDAgMCAxLTcuNzM1LTcuNzM0di04OC42OEMxNTIuNjE1IDUuMzI3IDE0Ny4yOSAwIDE0MC43MjYgMGgtMzAuMzc1Yy02LjU2OCAwLTExLjg5IDUuMzI3LTExLjg5IDExLjg5NHY4OC4xNDNjMCA0LjU3My0zLjY5NyA4LjI5LTguMjcgOC4zMWwtMjcuODg1LjEzM2MtNC42MT [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/kamelet.group: "RabbitMQ"
+ camel.apache.org/kamelet.namespace: "Messaging"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+spec:
+ definition:
+ title: "RabbitMQ Source"
+ description: |-
+ Receive data from a RabbitMQ Broker.
+ required:
+ - addresses
+ - exchangeName
+ type: object
+ properties:
+ host:
+ title: Server Address
+ description: RabbitMQ broker address
+ type: string
+ example: "localhost"
+ port:
+ title: Server Port
+ description: RabbitMQ broker port
+ type: int
+ example: 5672
+ routingKey:
+ title: Routing Key
+ description: The routing key to use when binding a consumer queue to the exchange
+ type: string
+ username:
+ title: Username
+ description: The username to access the RabbitMQ server
+ type: string
+ x-descriptors:
+ - urn:camel:group:credentials
+ password:
+ title: Password
+ description: The password to access the RabbitMQ server
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ exchangeName:
+ title: Exchange name
+ description: The exchange name determines the exchange the queue will be bound to
+ type: string
+ queues:
+ title: Queue name
+ description: The queue to receive messages from
+ type: string
+ autoDeclare:
+ title: Auto Declare
+ description: The routing key to use when binding a consumer queue to the exchange
+ type: boolean
+ default: false
+ dependencies:
+ - "camel:spring-rabbitmq"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: connectionFactory
+ type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
+ properties:
+ username: '{{username}}'
+ password: '{{password}}'
+ host: '{{host}}'
+ port: '{{port}}'
+ from:
+ uri: "spring-rabbitmq://{{exchangeName}}"
+ parameters:
+ connectionFactory: "#bean:{{connectionFactory}}"
+ routingKey: "{{?routingKey}}"
+ queues: "{{?queue}}"
+ autoDeclare: "{{autoDeclare}}"
+ steps:
+ - to: "kamelet:sink"
(camel-kamelets) 05/08: Added Spring-RabbitMQ Sink Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3055de90b9a4450840fa4574c5da93f50081722d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:06:49 2024 +0100
Added Spring-RabbitMQ Sink Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/spring-rabbitmq-sink.kamelet.yaml | 96 ++++++++++++++++++++++++++++++
1 file changed, 96 insertions(+)
diff --git a/kamelets/spring-rabbitmq-sink.kamelet.yaml b/kamelets/spring-rabbitmq-sink.kamelet.yaml
new file mode 100644
index 00000000..1c0b3ef2
--- /dev/null
+++ b/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -0,0 +1,96 @@
+# ---------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ---------------------------------------------------------------------------
+apiVersion: camel.apache.org/v1
+kind: Kamelet
+metadata:
+ name: spring-rabbitmq-sink
+ annotations:
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/catalog.version: "4.4.0-SNAPSHOT"
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjcxcHgiIGhlaWdodD0iMjcxcHgiIHZpZXdCb3g9Ii03LjUgMCAyNzEgMjcxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHByZXNlcnZlQXNwZWN0UmF0aW89InhNaWRZTWlkIj48cGF0aCBkPSJNMjQ1LjQ0IDEwOC4zMDhoLTg1LjA5YTcuNzM4IDcuNzM4IDAgMCAxLTcuNzM1LTcuNzM0di04OC42OEMxNTIuNjE1IDUuMzI3IDE0Ny4yOSAwIDE0MC43MjYgMGgtMzAuMzc1Yy02LjU2OCAwLTExLjg5IDUuMzI3LTExLjg5IDExLjg5NHY4OC4xNDNjMCA0LjU3My0zLjY5NyA4LjI5LTguMjcgOC4zMWwtMjcuODg1LjEzM2MtNC42MT [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/kamelet.group: "RabbitMQ"
+ camel.apache.org/kamelet.namespace: "Messaging"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+spec:
+ definition:
+ title: "RabbitMQ Sink"
+ description: |-
+ Send data to a RabbitMQ Broker.
+ required:
+ - addresses
+ - exchangeName
+ type: object
+ properties:
+ host:
+ title: Server Address
+ description: RabbitMQ broker address
+ type: string
+ example: "localhost"
+ port:
+ title: Server Port
+ description: RabbitMQ broker port
+ type: int
+ example: 5672
+ routingKey:
+ title: Routing Key
+ description: The routing key to use when binding a consumer queue to the exchange
+ type: string
+ username:
+ title: Username
+ description: The username to access the RabbitMQ server
+ type: string
+ x-descriptors:
+ - urn:camel:group:credentials
+ password:
+ title: Password
+ description: The password to access the RabbitMQ server
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ exchangeName:
+ title: Exchange name
+ description: The exchange name determines the exchange the queue will be bound to
+ type: string
+ queues:
+ title: Queue name
+ description: The queue to receive messages from
+ type: string
+ dependencies:
+ - "camel:spring-rabbitmq"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: connectionFactory
+ type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
+ properties:
+ username: '{{username}}'
+ password: '{{password}}'
+ host: '{{host}}'
+ port: '{{port}}'
+ from:
+ uri: "kamelet:source"
+ steps:
+ - to:
+ uri: "spring-rabbitmq://{{exchangeName}}"
+ parameters:
+ connectionFactory: "#bean:{{connectionFactory}}"
+ routingKey: "{{?routingKey}}"
+ queues: "{{?queue}}"
(camel-kamelets) 07/08: Added Spring-RabbitMQ Sink and Source Kamelet
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 4621ff0011a43185119fba8bae370f991cc0a652
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Feb 14 14:11:04 2024 +0100
Added Spring-RabbitMQ Sink and Source Kamelet
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
docs/modules/ROOT/nav.adoc | 2 ++
kamelets/spring-rabbitmq-sink.kamelet.yaml | 7 ++++---
kamelets/spring-rabbitmq-source.kamelet.yaml | 7 ++++---
.../src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml | 7 ++++---
.../main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml | 7 ++++---
5 files changed, 18 insertions(+), 12 deletions(-)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index e60bc8a1..c8f6e470 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -216,6 +216,8 @@
* xref:splunk-hec-sink.adoc[]
* xref:splunk-sink.adoc[]
* xref:splunk-source.adoc[]
+* xref:spring-rabbitmq-sink.adoc[]
+* xref:spring-rabbitmq-source.adoc[]
* xref:sqlserver-sink.adoc[]
* xref:sqlserver-source.adoc[]
* xref:ssh-sink.adoc[]
diff --git a/kamelets/spring-rabbitmq-sink.kamelet.yaml b/kamelets/spring-rabbitmq-sink.kamelet.yaml
index 1c0b3ef2..d2cf135d 100644
--- a/kamelets/spring-rabbitmq-sink.kamelet.yaml
+++ b/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
description: |-
Send data to a RabbitMQ Broker.
required:
- - addresses
+ - host
+ - port
- exchangeName
type: object
properties:
@@ -81,8 +82,8 @@ spec:
- name: connectionFactory
type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
properties:
- username: '{{username}}'
- password: '{{password}}'
+ username: '{{?username}}'
+ password: '{{?password}}'
host: '{{host}}'
port: '{{port}}'
from:
diff --git a/kamelets/spring-rabbitmq-source.kamelet.yaml b/kamelets/spring-rabbitmq-source.kamelet.yaml
index 78c94e4c..c4101166 100644
--- a/kamelets/spring-rabbitmq-source.kamelet.yaml
+++ b/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
description: |-
Receive data from a RabbitMQ Broker.
required:
- - addresses
+ - host
+ - port
- exchangeName
type: object
properties:
@@ -86,8 +87,8 @@ spec:
- name: connectionFactory
type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
properties:
- username: '{{username}}'
- password: '{{password}}'
+ username: '{{?username}}'
+ password: '{{?password}}'
host: '{{host}}'
port: '{{port}}'
from:
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
index 1c0b3ef2..d2cf135d 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-sink.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
description: |-
Send data to a RabbitMQ Broker.
required:
- - addresses
+ - host
+ - port
- exchangeName
type: object
properties:
@@ -81,8 +82,8 @@ spec:
- name: connectionFactory
type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
properties:
- username: '{{username}}'
- password: '{{password}}'
+ username: '{{?username}}'
+ password: '{{?password}}'
host: '{{host}}'
port: '{{port}}'
from:
diff --git a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
index 78c94e4c..c4101166 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/spring-rabbitmq-source.kamelet.yaml
@@ -33,7 +33,8 @@ spec:
description: |-
Receive data from a RabbitMQ Broker.
required:
- - addresses
+ - host
+ - port
- exchangeName
type: object
properties:
@@ -86,8 +87,8 @@ spec:
- name: connectionFactory
type: "#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
properties:
- username: '{{username}}'
- password: '{{password}}'
+ username: '{{?username}}'
+ password: '{{?password}}'
host: '{{host}}'
port: '{{port}}'
from: