Merge pull request #1292 from ozangunalp/pulsar_quickstarts

Reactive Messaging Pulsar quickstart

Author: cescoffier

README.md

@@ -76,6 +76,7 @@ See [CONTRIBUTING](CONTRIBUTING.md) for how to build these examples.
 * [MongoDB with Panache](./mongodb-panache-quickstart): Simplify your MongoDB applications with Panache
 * [MicroProfile Messaging MQTT](./mqtt-quickstart): How to interact with MQTT using MicroProfile reactive messaging
 * [Neo4j](./neo4j-quickstart): How to connect to a Neo4j graph datastore
+* [Pulsar](./pulsar-quickstart):  How to interact with Apache Pulsar using MicroProfile reactive messaging
 * [OpenAPI and Swagger UI](./openapi-swaggerui-quickstart): Use OpenAPI and Swagger UI to expose your REST API and test your REST services
 * [OpenTelemetry](./opentelemetry-quickstart): How to use OpenTelemetry to monitor application performance
 * [OpenTracing and Jaeger](./opentracing-quickstart): How to use MicroProfile OpenTracing and Jaeger to monitor application performances

pom.xml

@@ -67,6 +67,7 @@
         <module>openapi-swaggerui-quickstart</module>
         <module>opentracing-quickstart</module>
         <module>opentelemetry-quickstart</module>
+        <module>pulsar-quickstart</module>
         <module>quartz-quickstart</module>
         <module>qute-quickstart</module>
         <module>rabbitmq-quickstart</module>

pulsar-quickstart/.mvn/wrapper/maven-wrapper.jar

@@ -0,0 +1,18 @@
+# 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
+#
+#   https://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.
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.6/apache-maven-3.8.6-bin.zip
+wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar

pulsar-quickstart/.mvn/wrapper/maven-wrapper.properties

@@ -0,0 +1,61 @@
+Quarkus Pulsar Quickstart
+============================
+
+This project illustrates how you can interact with Apache Pulsar using MicroProfile Reactive Messaging.
+The complete instructions are available on https://quarkus.io/guides/pulsar-quickstart.
+
+## Start the application in dev mode
+
+In a first terminal, run:
+
+```bash
+> mvn -f pulsar-quickstart-producer quarkus:dev
+```
+
+In a second terminal, run:
+
+```bash
+> mvn -f pulsar-quickstart-processor quarkus:dev
+```  
+
+Then, open your browser to `http://localhost:8080/quotes.html`, and click on the "Request Quote" button.
+
+## Build the application in JVM mode
+
+To build the applications, run:
+
+```bash
+> mvn -f pulsar-quickstart-producer package
+> mvn -f pulsar-quickstart-processor package
+```
+
+Because we are running in _prod_ mode, we need to provide an pulsar broker.
+The [docker-compose.yml](docker-compose.yml) file starts the broker and your application.
+
+Start the broker and the applications using:
+
+```bash
+> docker compose up --build
+```
+
+Then, open your browser to `http://localhost:8080/quotes.html`, and click on the "Request Quote" button.
+ 
+
+## Build the application in native mode
+
+To build the applications into native executables, run:
+
+```bash
+> mvn -f pulsar-quickstart-producer package -Pnative  -Dquarkus.native.container-build=true
+> mvn -f pulsar-quickstart-processor package -Pnative -Dquarkus.native.container-build=true
+```
+
+The `-Dquarkus.native.container-build=true` instructs Quarkus to build Linux 64bits native executables, who can run inside containers.  
+
+Then, start the system using:
+
+```bash
+> export QUARKUS_MODE=native
+> docker compose up
+```
+Then, open your browser to `http://localhost:8080/quotes.html`, and click on the "Request Quote" button.

pulsar-quickstart/README.md

@@ -0,0 +1,66 @@
+version: '3.8'
+
+services:
+
+  pulsar:
+    image: apachepulsar/pulsar:3.0.0
+    command: [
+      "sh", "-c",
+      "bin/apply-config-from-env.py conf/standalone.conf && bin/pulsar standalone -nfw -nss"
+    ]
+    
+    ports:
+      - "6650:6650"
+      - "8080:8080"
+    tmpfs:
+      - /pulsar/data
+    healthcheck:
+      test: curl --fail http://localhost:8080/admin/v2/clusters || exit 1
+      interval: 10s
+      timeout: 10s
+      retries: 5
+      start_period: 5s
+    environment:
+      PULSAR_PREFIX_advertisedListeners: internal:pulsar://localhost:6650,external:pulsar://pulsar:6650
+      PULSAR_PREFIX_transactionCoordinatorEnabled: true
+      PULSAR_PREFIX_systemTopicEnabled: true
+    networks:
+      - pulsar-quickstart-network
+
+  producer:
+    image: quarkus-quickstarts/pulsar-quickstart-producer:1.0-${QUARKUS_MODE:-jvm}
+    depends_on:
+      pulsar:
+        condition: service_healthy
+    build:
+      context: pulsar-quickstart-producer
+      dockerfile: src/main/docker/Dockerfile.${QUARKUS_MODE:-jvm}
+    deploy:
+      restart_policy:
+        condition: on-failure
+    environment:
+      PULSAR_CLIENT_SERVICE_URL: pulsar://pulsar:6650
+    ports:
+      - "8082:8080"
+    networks:
+      - pulsar-quickstart-network
+
+  processor:
+    image: quarkus-quickstarts/pulsar-quickstart-processor:1.0-${QUARKUS_MODE:-jvm}
+    depends_on:
+      pulsar:
+        condition: service_healthy
+    build:
+      context: pulsar-quickstart-processor
+      dockerfile: src/main/docker/Dockerfile.${QUARKUS_MODE:-jvm}
+    deploy:
+      restart_policy:
+        condition: on-failure
+    environment:
+      PULSAR_CLIENT_SERVICE_URL: pulsar://pulsar:6650
+    networks:
+      - pulsar-quickstart-network
+
+networks:
+  pulsar-quickstart-network:
+    name: pulsar-quickstart