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/05/06 09:37:26 UTC

[camel-kamelets] branch main updated (9d3abfa1 -> dcbccfb1)

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 9d3abfa1 Upgrade PostgreSQL Driver to version 42.3.4
     new 985f80fc aws-* kamelets: expose delay parameter where possible - AWS S3
     new fb21c4c5 aws-* kamelets: expose delay parameter where possible - AWS S3
     new 0849f3fc aws-* kamelets: expose delay parameter where possible - AWS Kinesis
     new 8fd69e8c aws-* kamelets: expose delay parameter where possible - AWS Kinesis
     new e0a3c945 aws-* kamelets: expose delay parameter where possible - AWS Kinesis
     new 5e764a09 aws-* kamelets: expose delay parameter where possible - AWS Kinesis
     new d54b6f59 aws-* kamelets: expose delay parameter where possible - AWS Redshift
     new 5af216d2 aws-* kamelets: expose delay parameter where possible - AWS Redshift
     new 45b80be8 aws-* kamelets: expose delay parameter where possible - AWS DDB Streams
     new 90295044 aws-* kamelets: expose delay parameter where possible - AWS DDB Streams
     new 41931e3d aws-* kamelets: expose delay parameter where possible - AWS SQS
     new f5463e37 aws-* kamelets: expose delay parameter where possible - AWS SQS
     new dcbccfb1 aws-* kamelets: expose delay parameter where possible

The 13 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:
 kamelets/aws-ddb-streams-source.kamelet.yaml                   |  6 ++++++
 kamelets/aws-kinesis-source.kamelet.yaml                       |  6 ++++++
 kamelets/aws-redshift-source.kamelet.yaml                      |  6 ++++++
 kamelets/aws-s3-source.kamelet.yaml                            |  6 ++++++
 kamelets/aws-sqs-source.kamelet.yaml                           | 10 ++++++++--
 .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java |  2 +-
 .../resources/kamelets/aws-ddb-streams-source.kamelet.yaml     |  6 ++++++
 .../main/resources/kamelets/aws-kinesis-source.kamelet.yaml    |  6 ++++++
 .../main/resources/kamelets/aws-redshift-source.kamelet.yaml   |  6 ++++++
 .../src/main/resources/kamelets/aws-s3-source.kamelet.yaml     |  6 ++++++
 .../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml    | 10 ++++++++--
 11 files changed, 65 insertions(+), 5 deletions(-)


[camel-kamelets] 10/13: aws-* kamelets: expose delay parameter where possible - AWS DDB Streams

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 9029504403f6472858e5fa1936bba2bfdf5fdc3c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:07:55 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS DDB Streams
---
 .../src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
index 378f128d..c1709e85 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
@@ -89,6 +89,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -107,6 +112,7 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json:


[camel-kamelets] 02/13: aws-* kamelets: expose delay parameter where possible - AWS S3

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 fb21c4c553c16070c8244332fd0ecb224f406f7b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 10:56:13 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS S3
---
 .../src/main/resources/kamelets/aws-s3-source.kamelet.yaml          | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
index 2b5f05d0..a2da4433 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
@@ -100,6 +100,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected bucket
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-s3"
     - "camel:kamelet"
@@ -118,5 +123,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"


[camel-kamelets] 12/13: aws-* kamelets: expose delay parameter where possible - AWS SQS

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 f5463e3739393b9fa5b974539aab3d632dc2b83d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:12:31 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS SQS
---
 .../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml    | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
index 73b70b2e..238a3549 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
@@ -123,7 +123,12 @@ spec:
         type: boolean
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
-        default: false    
+        default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected stream
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-sqs"
     - "camel:kamelet"
@@ -140,6 +145,7 @@ spec:
         protocol: "{{?protocol}}"
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
-        overrideEndpoint: "{{overrideEndpoint}}"  
+        overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"  
       steps:
       - to: "kamelet:sink"


[camel-kamelets] 06/13: aws-* kamelets: expose delay parameter where possible - AWS Kinesis

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 5e764a0998edfb6c2f5df83732d614d7a077a7cd
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:00:49 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS Kinesis
---
 .../src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
index 19ef76b9..4ffbea0a 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
@@ -86,7 +86,7 @@ spec:
         default: false
       delay:
         title: Delay
-        description: Milliseconds before the next poll of the selected bucket
+        description: Milliseconds before the next poll of the selected stream
         type: long
         default: 500
   types:


[camel-kamelets] 13/13: aws-* kamelets: expose delay parameter where possible

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 dcbccfb1395e72cba804d6cd7af3bb4cc13e5095
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:21:48 2022 +0200

    aws-* kamelets: expose delay parameter where possible
---
 .../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
index 669bba8c..93dc60de 100644
--- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
+++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
@@ -54,7 +54,7 @@ public class KameletsCatalogTest {
     @Test
     void testGetKameletsDefinition() throws Exception {
         JSONSchemaProps props = catalog.getKameletDefinition("aws-sqs-source");
-        assertEquals(12, props.getProperties().keySet().size());
+        assertEquals(13, props.getProperties().keySet().size());
         assertTrue(props.getProperties().keySet().contains("queueNameOrArn"));
     }
 


[camel-kamelets] 03/13: aws-* kamelets: expose delay parameter where possible - AWS Kinesis

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 0849f3fc562f9cf84a300aa82e9c662b1e6d3385
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 10:57:54 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS Kinesis
---
 kamelets/aws-kinesis-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml
index 45f3b793..19ef76b9 100644
--- a/kamelets/aws-kinesis-source.kamelet.yaml
+++ b/kamelets/aws-kinesis-source.kamelet.yaml
@@ -84,6 +84,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected bucket
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/octet-stream
@@ -101,5 +106,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"


[camel-kamelets] 04/13: aws-* kamelets: expose delay parameter where possible - AWS Kinesis

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 8fd69e8c61059aed6a262d75a44913876e531130
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 10:58:52 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS Kinesis
---
 .../src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
index 45f3b793..19ef76b9 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
@@ -84,6 +84,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected bucket
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/octet-stream
@@ -101,5 +106,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"


[camel-kamelets] 07/13: aws-* kamelets: expose delay parameter where possible - AWS Redshift

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 d54b6f5923bf8518627c133b0d87b749e3c03e19
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:01:49 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS Redshift
---
 kamelets/aws-redshift-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/aws-redshift-source.kamelet.yaml b/kamelets/aws-redshift-source.kamelet.yaml
index 78d4b1f2..9bb86db7 100644
--- a/kamelets/aws-redshift-source.kamelet.yaml
+++ b/kamelets/aws-redshift-source.kamelet.yaml
@@ -77,6 +77,11 @@ spec:
         description: A query to run on a tuple consumed
         type: string
         example: 'DELETE FROM accounts where user_id = :#user_id'
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -104,6 +109,7 @@ spec:
       parameters:
         dataSource: "#bean:{{dsBean}}"
         onConsume: "{{?consumedQuery}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json: 


[camel-kamelets] 05/13: aws-* kamelets: expose delay parameter where possible - AWS Kinesis

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 e0a3c945af7aa7bf6ca01e90c6a82d027b638bb8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:00:11 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS Kinesis
---
 kamelets/aws-kinesis-source.kamelet.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml
index 19ef76b9..4ffbea0a 100644
--- a/kamelets/aws-kinesis-source.kamelet.yaml
+++ b/kamelets/aws-kinesis-source.kamelet.yaml
@@ -86,7 +86,7 @@ spec:
         default: false
       delay:
         title: Delay
-        description: Milliseconds before the next poll of the selected bucket
+        description: Milliseconds before the next poll of the selected stream
         type: long
         default: 500
   types:


[camel-kamelets] 11/13: aws-* kamelets: expose delay parameter where possible - AWS SQS

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 41931e3d79a3b7d34d97c80fb5b98f89c932cdbc
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:10:20 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS SQS
---
 kamelets/aws-sqs-source.kamelet.yaml | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/kamelets/aws-sqs-source.kamelet.yaml b/kamelets/aws-sqs-source.kamelet.yaml
index 73b70b2e..238a3549 100644
--- a/kamelets/aws-sqs-source.kamelet.yaml
+++ b/kamelets/aws-sqs-source.kamelet.yaml
@@ -123,7 +123,12 @@ spec:
         type: boolean
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
-        default: false    
+        default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected stream
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-sqs"
     - "camel:kamelet"
@@ -140,6 +145,7 @@ spec:
         protocol: "{{?protocol}}"
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
-        overrideEndpoint: "{{overrideEndpoint}}"  
+        overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"  
       steps:
       - to: "kamelet:sink"


[camel-kamelets] 09/13: aws-* kamelets: expose delay parameter where possible - AWS DDB Streams

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 45b80be8d1fead16ebf6cb5d460aebea4d7f2f57
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:06:01 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS DDB Streams
---
 kamelets/aws-ddb-streams-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/aws-ddb-streams-source.kamelet.yaml b/kamelets/aws-ddb-streams-source.kamelet.yaml
index 378f128d..c1709e85 100644
--- a/kamelets/aws-ddb-streams-source.kamelet.yaml
+++ b/kamelets/aws-ddb-streams-source.kamelet.yaml
@@ -89,6 +89,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -107,6 +112,7 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json:


[camel-kamelets] 01/13: aws-* kamelets: expose delay parameter where possible - AWS S3

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 985f80fc014b23d06eb186923b0951cfd889d277
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 10:55:20 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS S3
---
 kamelets/aws-s3-source.kamelet.yaml | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kamelets/aws-s3-source.kamelet.yaml b/kamelets/aws-s3-source.kamelet.yaml
index 2b5f05d0..a2da4433 100644
--- a/kamelets/aws-s3-source.kamelet.yaml
+++ b/kamelets/aws-s3-source.kamelet.yaml
@@ -100,6 +100,11 @@ spec:
         x-descriptors:
           - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
         default: false
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll of the selected bucket
+        type: long
+        default: 500
   dependencies:
     - "camel:aws2-s3"
     - "camel:kamelet"
@@ -118,5 +123,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
+        delay: "{{delay}}"
       steps:
       - to: "kamelet:sink"


[camel-kamelets] 08/13: aws-* kamelets: expose delay parameter where possible - AWS Redshift

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 5af216d2ddb6b887d42d665430aa223849be950c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri May 6 11:02:27 2022 +0200

    aws-* kamelets: expose delay parameter where possible - AWS Redshift
---
 .../src/main/resources/kamelets/aws-redshift-source.kamelet.yaml    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml
index 78d4b1f2..9bb86db7 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-redshift-source.kamelet.yaml
@@ -77,6 +77,11 @@ spec:
         description: A query to run on a tuple consumed
         type: string
         example: 'DELETE FROM accounts where user_id = :#user_id'
+      delay:
+        title: Delay
+        description: Milliseconds before the next poll from database
+        type: long
+        default: 500
   types:
     out:
       mediaType: application/json
@@ -104,6 +109,7 @@ spec:
       parameters:
         dataSource: "#bean:{{dsBean}}"
         onConsume: "{{?consumedQuery}}"
+        delay: "{{delay}}"
       steps:
       - marshal:
           json: