[camel-kamelets-examples] 01/02: Add http streaming example

[da...@apache.org]

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

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

commit 5adf86d2ba7af0e904ff13a5d31d3d89567b0cbb
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Aug 9 13:06:11 2022 +0200

    Add http streaming example
---
 jbang/http-streaming/MyHttpServer.java | 51 ++++++++++++++++++++++++++++
 jbang/http-streaming/README.adoc       | 61 ++++++++++++++++++++++++++++++++++
 jbang/http-streaming/my-stream.yaml    |  9 +++++
 3 files changed, 121 insertions(+)

diff --git a/jbang/http-streaming/MyHttpServer.java b/jbang/http-streaming/MyHttpServer.java
new file mode 100644
index 0000000..4f4652e
--- /dev/null
+++ b/jbang/http-streaming/MyHttpServer.java
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import com.sun.net.httpserver.HttpContext;
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpServer;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.InetSocketAddress;
+
+public class MyHttpServer {
+
+  public static void main(String[] args) throws Exception {
+      HttpServer server = HttpServer.create(new InetSocketAddress(8500), 0);
+      HttpContext context = server.createContext("/");
+      context.setHandler(MyHttpServer::handleRequest);
+      System.out.println("http://localhost:8500");
+      server.start();
+  }
+
+  private static void handleRequest(HttpExchange exchange) throws IOException {
+      exchange.sendResponseHeaders(200, 0);
+      OutputStream os = exchange.getResponseBody();
+      for (int i = 0; i < 100; i++) {
+        String response = "Hello " + i + "\n";
+        os.write(response.getBytes());
+        os.flush();
+        System.out.println("... " + i);
+        try {
+          Thread.sleep(1000);
+        } catch (Exception e) {
+          // ignore
+        }
+      }
+      os.close();
+  }
+}
\ No newline at end of file
diff --git a/jbang/http-streaming/README.adoc b/jbang/http-streaming/README.adoc
new file mode 100644
index 0000000..36946c7
--- /dev/null
+++ b/jbang/http-streaming/README.adoc
@@ -0,0 +1,61 @@
+== HTTP Streaming
+
+This example shows how Camel can continuously read HTTP streaming data, from a remote HTTP server.
+The HTTP server is expected to send data back in chunks separated by new-line (HTTP streaming).
+
+=== Install JBang
+
+First install JBang according to https://www.jbang.dev
+
+When JBang is installed then you should be able to run from a shell:
+
+[source,sh]
+----
+$ jbang --version
+----
+
+This will output the version of JBang.
+
+To run this example you can either install Camel on JBang via:
+
+[source,sh]
+----
+$ jbang app install camel@apache/camel
+----
+
+Which allows to run CamelJBang with `camel` as shown below.
+
+=== How to run
+
+You need to run the HTTP server first which can be done using Java:
+
+[source,sh]
+----
+$ java MyHttpServer.java
+----
+
+This starts a local HTTP server on port 8500
+
+Then you can run this example using:
+
+[source,sh]
+----
+$ camel run my-stream.yaml
+----
+
+Or run with JBang using the longer command line (without installing camel as app in JBang):
+
+[source,sh]
+----
+$ jbang camel@apache/camel run mystream.yaml
+----
+
+=== Help and contributions
+
+If you hit any problem using Camel or have some feedback, then please
+https://camel.apache.org/community/support/[let us know].
+
+We also love contributors, so
+https://camel.apache.org/community/contributing/[get involved] :-)
+
+The Camel riders!
diff --git a/jbang/http-streaming/my-stream.yaml b/jbang/http-streaming/my-stream.yaml
new file mode 100644
index 0000000..f1d17f8
--- /dev/null
+++ b/jbang/http-streaming/my-stream.yaml
@@ -0,0 +1,9 @@
+# camel-k: language=yaml
+
+- from:
+    uri: "stream:http"
+    parameters:
+      httpUrl: "http://localhost:8500"
+      scanStream: true
+    steps:
+      - log: "${body}"