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 2022/04/29 12:51:18 UTC

[camel-kamelets] branch stream-filter created (now a58175c7)

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch stream-filter
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git


      at a58175c7 MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter

This branch includes the following new commits:

     new e33cb6bb MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter
     new a58175c7 MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter

The 2 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.



[camel-kamelets] 01/02: MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch stream-filter
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit e33cb6bb88ae44a2c46a643b2861256ab5c9fe51
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 29 14:48:26 2022 +0200

    MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter
---
 kamelets/mongodb-changes-stream-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/mongodb-changes-stream-source.kamelet.yaml b/kamelets/mongodb-changes-stream-source.kamelet.yaml
index a5f4e025..3095dfcd 100644
--- a/kamelets/mongodb-changes-stream-source.kamelet.yaml
+++ b/kamelets/mongodb-changes-stream-source.kamelet.yaml
@@ -63,6 +63,11 @@ spec:
         title: MongoDB Database
         description: Sets the name of the MongoDB database to target.
         type: string
+      streamFilter:
+        title: Stream Filter
+        description: Filter condition for change streams consumer.
+        type: string
+        example: "{ '$match':{'$or':[{'fullDocument.stringValue': 'specificValue'}]} }"
   dependencies:
     - "camel:kamelet"
     - "camel:mongodb"
@@ -80,6 +85,7 @@ spec:
         username: "{{?username}}"
         database: "{{database}}"
         consumerType: "changeStreams"
+        streamFilter: "{{?streamFilter}}"
       steps:
       - marshal:
           json: {}


[camel-kamelets] 02/02: MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch stream-filter
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit a58175c76f5a8ca0b75b7431fce27128182cc23d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Apr 29 14:49:28 2022 +0200

    MongoDB Changes Stream Consumer Source Kamelet - Stream Filter parameter
---
 .../resources/kamelets/mongodb-changes-stream-source.kamelet.yaml   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml
index a5f4e025..3095dfcd 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/mongodb-changes-stream-source.kamelet.yaml
@@ -63,6 +63,11 @@ spec:
         title: MongoDB Database
         description: Sets the name of the MongoDB database to target.
         type: string
+      streamFilter:
+        title: Stream Filter
+        description: Filter condition for change streams consumer.
+        type: string
+        example: "{ '$match':{'$or':[{'fullDocument.stringValue': 'specificValue'}]} }"
   dependencies:
     - "camel:kamelet"
     - "camel:mongodb"
@@ -80,6 +85,7 @@ spec:
         username: "{{?username}}"
         database: "{{database}}"
         consumerType: "changeStreams"
+        streamFilter: "{{?streamFilter}}"
       steps:
       - marshal:
           json: {}