[camel-kamelets] 01/04: Added Infinispan Source Kamelet

[ac...@apache.org]

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

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

commit ad903b758419763d00d68420bcdd5aac3b6655db
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 28 13:41:26 2021 +0200

    Added Infinispan Source Kamelet
---
 infinispan-source.kamelet.yaml | 80 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 80 insertions(+)

diff --git a/infinispan-source.kamelet.yaml b/infinispan-source.kamelet.yaml
new file mode 100755
index 0000000..d87b688
--- /dev/null
+++ b/infinispan-source.kamelet.yaml
@@ -0,0 +1,80 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+  name: infinispan-source
+  labels:
+    camel.apache.org/kamelet.type: "source"
+  annotations:
+    camel.apache.org/provider: "Apache Software Foundation"
+    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiPz4KPHN2ZyBlbmFibGUtYmFja2dyb3VuZD0ibmV3IDAgMCA1NTAgMjUwIiB2aWV3Qm94PSI3Nyw4Myw0MTAsOTAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiA8cGF0aCBkPSJtMTc4IDEwMi41aDMxM3Y0MWgtMzEzeiIgZmlsbD0ibm9uZSIvPgogPGcgZW5hYmxlLWJhY2tncm91bmQ9Im5ldyI+CiAgPHBhdGggZD0ibTE5My4zIDEzOS40Yy00IDAtNy4yLTEuMi05LjUtMy41cy0zLjQtNS42LTMuNC05LjdjMC00LjIgMS4xLTcuNiAzLjItMTBzNS0zLjYgOC43LTMuNmMzLjQgMCA2Lj [...]
+spec:
+  sources:
+    - content: |-
+        public class InfinispanWorkaround extends org.apache.camel.builder.RouteBuilder {
+          @Override
+          public void configure() throws Exception {
+            getContext().setAutowiredEnabled(false);
+          }
+        }
+      name: InfinispanWorkaround.java
+  definition:
+    title: "Infinispan Source"
+    description: |-
+      Get Events from an Infinispan cache
+    required:
+      - hosts
+      - username
+      - password
+      - hostAddresses
+    properties:
+      hosts:
+        title: Hosts
+        description: Specifies the host of the cache on Infinispan instance
+        type: String
+        default: 1000
+      secure:
+        title: Secure
+        description: If the Infinispan instance is secured or not
+        type: boolean
+        default: true
+      username:
+        title: Username
+        description: Username to connect to Infinispan.
+        type: string
+      password:
+        title: Password
+        description: Password to connect to Infinispan.
+        type: string
+      saslMechanism:
+        title: SASL Mechanism
+        description: The SASL Mechanism to use
+        type: String
+        default: "DIGEST-MD5"
+      securityRealm:
+        title: Security Realm
+        description: Define the security realm to access the infinispan instance
+        type: string
+        default: "default"
+      securityServerName:
+        title: Security Server name
+        description: Define the security server name to access the infinispan instance
+        type: string
+        default: "infinispan"
+      eventTypes:
+        title: ElasticSearch cluster name
+        description: Specifies the set of event types to register by the consumer.Multiple event can be separated by comma. The possible event types are CLIENT_CACHE_ENTRY_CREATED, CLIENT_CACHE_ENTRY_MODIFIED, CLIENT_CACHE_ENTRY_REMOVED, CLIENT_CACHE_ENTRY_EXPIRED, CLIENT_CACHE_FAILOVER
+        type: string
+  flow:
+    from:
+      uri: "kamelet-reify:infinispan:{{cacheName}}"
+      parameters:
+        hosts: "{{hosts}}"
+        secure: "{{secure}}"
+        username: "{{username}}"
+        password: "{{password}}"
+        saslMechanism: "{{saslMechanism}}"
+        securityRealm: "{{securityRealm}}"
+        securityServerName: "{{securityServerName}}"
+        eventTypes: "{{eventTypes}}"
+      steps:
+        - to: kamelet:sink