You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ma...@apache.org on 2022/05/24 19:07:28 UTC
[camel-karavan] branch main updated: Delete old (#351)
This is an automated email from the ASF dual-hosted git repository.
marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push:
new f2af7dd Delete old (#351)
f2af7dd is described below
commit f2af7ddd729e042fe212115819a2072f206e707b
Author: Marat Gubaidullin <ma...@gmail.com>
AuthorDate: Tue May 24 15:07:24 2022 -0400
Delete old (#351)
---
.../postman-openshift/CustomProcessor.java | 11 --
karavan-demo/postman-openshift/README.md | 59 ---------
.../postman-openshift/application.properties | 34 ------
karavan-demo/postman-openshift/builder.png | Bin 143031 -> 0 bytes
karavan-demo/postman-openshift/deploy.png | Bin 129412 -> 0 bytes
.../postman-openshift/openshift.properties | 32 -----
karavan-demo/postman-openshift/operators.png | Bin 96712 -> 0 bytes
karavan-demo/postman-openshift/parcels.png | Bin 326798 -> 0 bytes
karavan-demo/postman-openshift/postman.yaml | 133 ---------------------
9 files changed, 269 deletions(-)
diff --git a/karavan-demo/postman-openshift/CustomProcessor.java b/karavan-demo/postman-openshift/CustomProcessor.java
deleted file mode 100644
index 17399cf..0000000
--- a/karavan-demo/postman-openshift/CustomProcessor.java
+++ /dev/null
@@ -1,11 +0,0 @@
-import org.apache.camel.BindToRegistry;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-
-@BindToRegistry("myBean")
-public class CustomProcessor implements Processor {
-
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setBody("Hello world");
- }
-}
diff --git a/karavan-demo/postman-openshift/README.md b/karavan-demo/postman-openshift/README.md
deleted file mode 100644
index 14cecbb..0000000
--- a/karavan-demo/postman-openshift/README.md
+++ /dev/null
@@ -1,59 +0,0 @@
-# Demo: Parcels Delivery Service on OpenShfit
-
-
-
-## Prerequisites
-
-1. [VSCode](https://code.visualstudio.com/download) installed
-2. Apache Camel [Karavan](https://marketplace.visualstudio.com/items?itemName=camel-karavan.karavan) extension installed
-3. [Jbang](https://www.jbang.dev/download/) installed
-4. OpenShift 4.9+ cluster up and running
-4. OpenShift 4.9+ CLI installed
-
-## How-to
-### Install AMQ and AMQ Streams Operators
-Also creates `postman` namespace required for the demo
-```
-oc apply -k manifests/operators
-```
-Check that operators are succesfully installed
-
-
-### Create AMQ, Kafka and Postgres demo instances
-```
-oc apply -k manifests/instances
-```
-
-### Package, build and deploy project
-1. Open Project builder
-
-
-2. Configure Project and click Start
-
-```
-
-```
-
-### Publish parcel
-```
-appsurl=$(oc get ingresses.config.openshift.io cluster -o template --template '{{.spec.domain}}')
-
-curl -X POST -H "Content-Type: application/json" --data '{"id":"1","address":"666 Sin Street, Holy City"}' http://postman-postman.$appsurl/parcels
-```
-### Publish payment
-Open AMQ7 Broker Management
-```
-open http://console-postman.$appsurl
-```
-
-Send message to `payments` queue
-```
-<?xml version="1.0" encoding="UTF-8" ?>
-<root>
- <id>1</id>
- <amount>777</amount>
- <status>confirmed</status>
-</root>
-```
-
-### Check postman logs and Database
\ No newline at end of file
diff --git a/karavan-demo/postman-openshift/application.properties b/karavan-demo/postman-openshift/application.properties
deleted file mode 100644
index d762bbe..0000000
--- a/karavan-demo/postman-openshift/application.properties
+++ /dev/null
@@ -1,34 +0,0 @@
-message=Hello world
-kafka=localhost:9092
-camel.jbang.project.name=demo-app
-camel.jbang.project.version=1.0.0
-camel.jbang.project.namespace=postman
-camel.jbang.project.cleanup=false
-camel.jbang.package=true
-camel.jbang.package.uber-jar.jar=camel-runner.jar
-camel.jbang.package.uber-jar.fresh=true
-camel.main.routesIncludePattern=file:CustomProcessor.java,file:postman.yaml
-camel.jbang.build.image=false
-camel.jbang.build.image.openshift=true
-camel.jbang.build.image.build-config=false
-camel.jbang.build.image.push=true
-camel.jbang.build.image.jar=camel-runner.jar
-camel.jbang.build.image.image=default/demo:1.0.0
-camel.jbang.build.image.source-image=java:openjdk-11-ubi8
-camel.jbang.build.image.from=gcr.io/distroless/java:11
-camel.jbang.deploy=false
-camel.jbang.deploy.openshift=true
-camel.jbang.deploy.minikube=false
-camel.jbang.deploy.image=default/demo:1.0.0
-camel.jbang.deploy.replicas=1
-camel.jbang.deploy.node-port=30777
-camel.jbang.undeploy.openshift=true
-camel.jbang.undeploy.minikube=false
-camel.jbang.manifests=true
-camel.jbang.manifests.path=true
-camel.jbang.manifests.openshift=true
-camel.jbang.manifests.minikube=false
-camel.jbang.manifests.image=default/demo:1.0.0
-camel.jbang.manifests.replicas=1
-camel.jbang.manifests.node-port=30777
-camel.jbang.manifests.jar=camel-runner.jar
\ No newline at end of file
diff --git a/karavan-demo/postman-openshift/builder.png b/karavan-demo/postman-openshift/builder.png
deleted file mode 100644
index 880bf92..0000000
Binary files a/karavan-demo/postman-openshift/builder.png and /dev/null differ
diff --git a/karavan-demo/postman-openshift/deploy.png b/karavan-demo/postman-openshift/deploy.png
deleted file mode 100644
index 67b343f..0000000
Binary files a/karavan-demo/postman-openshift/deploy.png and /dev/null differ
diff --git a/karavan-demo/postman-openshift/openshift.properties b/karavan-demo/postman-openshift/openshift.properties
deleted file mode 100644
index 04abf28..0000000
--- a/karavan-demo/postman-openshift/openshift.properties
+++ /dev/null
@@ -1,32 +0,0 @@
-kafka=kafka:9092
-camel.jbang.project.name=demo-openshift
-camel.jbang.project.version=1.0.0
-camel.jbang.project.namespace=default
-camel.jbang.project.cleanup=false
-camel.jbang.package=true
-camel.jbang.package.uber-jar.jar=camel-runner.jar
-camel.jbang.package.uber-jar.fresh=true
-camel.jbang.build.image=false
-camel.jbang.build.image.openshift=false
-camel.jbang.build.image.build-config=false
-camel.jbang.build.image.push=false
-camel.jbang.build.image.jar=camel-runner.jar
-camel.jbang.build.image.image=default/demo:1.0.0
-camel.jbang.build.image.source-image=java:openjdk-11-ubi8
-camel.jbang.build.image.from=gcr.io/distroless/java:11
-camel.jbang.deploy=false
-camel.jbang.deploy.openshift=false
-camel.jbang.deploy.minikube=true
-camel.jbang.deploy.image=default/demo:1.0.0
-camel.jbang.deploy.replicas=1
-camel.jbang.deploy.node-port=30777
-camel.jbang.undeploy.openshift=false
-camel.jbang.undeploy.minikube=true
-camel.jbang.manifests=true
-camel.jbang.manifests.path=true
-camel.jbang.manifests.openshift=false
-camel.jbang.manifests.minikube=true
-camel.jbang.manifests.image=default/demo:1.0.0
-camel.jbang.manifests.replicas=1
-camel.jbang.manifests.node-port=30777
-camel.jbang.manifests.jar=camel-runner.jar
\ No newline at end of file
diff --git a/karavan-demo/postman-openshift/operators.png b/karavan-demo/postman-openshift/operators.png
deleted file mode 100644
index 3582bcb..0000000
Binary files a/karavan-demo/postman-openshift/operators.png and /dev/null differ
diff --git a/karavan-demo/postman-openshift/parcels.png b/karavan-demo/postman-openshift/parcels.png
deleted file mode 100644
index 3cb70ff..0000000
Binary files a/karavan-demo/postman-openshift/parcels.png and /dev/null differ
diff --git a/karavan-demo/postman-openshift/postman.yaml b/karavan-demo/postman-openshift/postman.yaml
deleted file mode 100644
index c7e473b..0000000
--- a/karavan-demo/postman-openshift/postman.yaml
+++ /dev/null
@@ -1,133 +0,0 @@
-apiVersion: camel.apache.org/v1
-kind: Integration
-metadata:
- name: Postman Demo
-spec:
- flows:
- - rest:
- post:
- - to: direct:post
- path: /parcels
- consumes: application/json
- produces: application/json
- - route:
- from:
- uri: direct:post
- steps:
- - log:
- message: 'Received: ${body}'
- - multicast:
- steps:
- - to:
- uri: kamelet:kafka-not-secured-sink
- parameters:
- topic: parcels
- bootstrapServers: kafka-kafka-bootstrap:9092
- - to:
- uri: kamelet:postgresql-sink
- parameters:
- serverName: postgres
- serverPort: '5432'
- username: postgres
- password: postgres
- databaseName: demo
- query: >-
- INSERT INTO parcels (id,address) VALUES
- (:#id,:#address) ON CONFLICT (id) DO NOTHING
- aggregationStrategy: >-
- #class:org.apache.camel.processor.aggregate.UseOriginalAggregationStrategy
- parallelProcessing: true
- streaming: true
- id: post
- - route:
- from:
- uri: kamelet:jms-apache-artemis-source
- steps:
- - to:
- uri: xj:identity
- parameters:
- transformDirection: XML2JSON
- - to:
- uri: kamelet:kafka-not-secured-sink
- parameters:
- topic: payments
- bootstrapServers: kafka-kafka-bootstrap:9092
- parameters:
- destinationType: queue
- destinationName: payments
- brokerURL: tcp://amq-all-0-svc:61616
- id: payment
- - route:
- from:
- uri: kamelet:kafka-not-secured-source
- steps:
- - log:
- message: 'Aggegating: ${body}'
- - unmarshal:
- json:
- library: jackson
- - aggregate:
- steps:
- - choice:
- when:
- - expression:
- groovy:
- expression: >-
- body.find { it.containsKey('status') }.status ==
- 'confirmed'
- steps:
- - marshal:
- json:
- library: jackson
- - log:
- message: 'Send to MQTT : ${body}'
- - to:
- uri: kamelet:mqtt-sink
- parameters:
- topic: deliveries
- brokerUrl: tcp://amq-mqtt-0-svc:1883
- otherwise:
- steps:
- - setBody:
- expression:
- groovy:
- expression: 'body.find { it.containsKey(''status'') } '
- - marshal:
- json:
- library: jackson
- - log:
- message: 'Send to database: ${body}'
- - to:
- uri: kamelet:postgresql-sink
- parameters:
- serverName: postgres
- serverPort: '5432'
- username: postgres
- password: postgres
- databaseName: demo
- query: >-
- UPDATE parcels set status = 'CANCELED' WHERE
- id = :#id
- aggregationStrategy: aggregator
- completionSize: 2
- correlationExpression:
- groovy:
- expression: body.get('id')
- parameters:
- topic: parcels,payments
- bootstrapServers: kafka-kafka-bootstrap:9092
- autoCommitEnable: true
- consumerGroup: postman
- id: aggregator
- - route:
- from:
- uri: kamelet:mqtt-source
- steps:
- - log:
- message: 'Delivery: ${body}'
- parameters:
- topic: deliveries
- brokerUrl: tcp://amq-mqtt-0-svc:1883
- - beans:
- - name: aggregator
- type: org.apache.camel.processor.aggregate.GroupedBodyAggregationStrategy