07-aws-sqs-source-basic/aws-sqs-source.yaml (30 lines of code) (raw):

# # Apache Camel AWS Kinesis Source # apiVersion: sources.knative.dev/v1alpha1 kind: CamelSource metadata: name: camel-aws-sqs-source spec: source: integration: configuration: - type: secret value: aws-sqs dependencies: # Needed for the json part on the flow/steps below - camel:jackson # Needed for the AWS Kinesis component - camel:camel-aws2-sqs flow: from: # On the URI below, the queue named 'eventqueue' can be adjusted # to any value suitable in your scenario (ie.: aws-sqs:my-queue) uri: aws2-sqs:eventqueue parameters: secretKey: "{{aws.sqs.secretKey}}" accessKey: "{{aws.sqs.accessKey}}" region: "{{aws.sqs.region}}" deleteAfterRead: "true" steps: - to: "log:received?showAll=true&multiline=true" - marshal: json: {} sink: ref: apiVersion: messaging.knative.dev/v1beta1 kind: InMemoryChannel name: aws-sqs