Google Git
Sign in
apache/camel-k-examples/HEAD/./generic-examples/kamelets/timer-source
tree: 98c0ca420d65842d965bd39d29c9d54f1a2b5742
  1. kamelet-pipe-example.yaml
  2. messages-channel.yaml
  3. readme.md
  4. timer-source.kamelet.yaml
  5. usage.yaml
generic-examples/kamelets/timer-source/readme.md

Timer Source Hello World example

This example shows how to create a simple timer-source kamelet and how to use it in a new integration or how to bind it to a knative destination through a Pipe.

Timer Source Kamelet

First of all, you must install the timer source kamelet defined in timer-source.kamelet.yaml file:

$ kubectl apply -f timer-source.kamelet.yaml

You can check the newly created kamelet checking the list of kamelets available:

$ kubectl get kamelet timer-source

NAME                   PHASE
timer-source           Ready

Timer Source integration

As soon as the kamelet is available in your cluster, you can use it in any integration such as the one defined in usage.yaml file:

$ kamel run usage.yaml

You should be able to see the new integration running after some time:

$ kamel get
NAME	PHASE	KIT
usage	Running	kit-bu9d2r22hhmoa6qrtc2g

As soon as the integration starts, you will be able to log the timer source events emitted:

$ kamel log usage

[1] Monitoring pod usage-779f56b57dd-sqxrh
...
[1] 2022-08-20 08:20:57,927 INFO  [route1] (Camel (camel-1) thread #1 - timer://tick) Hello Kamelets
[1] 2022-08-20 08:20:58,927 INFO  [route1] (Camel (camel-1) thread #1 - timer://tick) Hello Kamelets
[1] 2022-08-20 08:20:59,927 INFO  [route1] (Camel (camel-1) thread #1 - timer://tick) Hello Kamelets
[1] 2022-08-20 08:21:00,928 INFO  [route1] (Camel (camel-1) thread #1 - timer://tick) Hello Kamelets
[1] 2022-08-20 08:21:01,927 INFO  [route1] (Camel (camel-1) thread #1 - timer://tick) Hello Kamelets
[1] 2022-08-20 08:21:02,928 INFO  [route1] (Camel (camel-1) thread #1 - timer://tick) Hello Kamelets
....

Timer Source KameletBinding

You can also bind the kamelet to a knative destination (or other events channel, see the official documention) in order to source the events emitted by the configuration described by the kamelet. Make sure to have Knative properly installed on your cluster (see installation guide).

First of all, you must declare the knative destination:

$ kubectl apply -f messages-channel.yaml

Once the destination is ready, you can reference it from a Pipe such as in the example kamelet-pipe-example.yaml. In order to bind the connector to the destination apply the configuration:

$ kubectl apply -f kamelet-pipe-example.yaml

You can confirm the creation of the KameletBinding listing the resources:

$ kubectl get pipes

NAME           PHASE
timer-source   Ready

At this stage you will be able to consume the timer event sources from the knative destination.