Creating reactive Java microservices

duration 20 minutes

Prerequisites:

Learn how to write reactive Java microservices using MicroProfile Reactive Messaging.

What you’ll learn

You will learn how to build reactive microservices that can send requests to other microservices, and asynchronously receive and process the responses. You will use an external messaging system to handle the asynchronous messages that are sent and received between the microservices as streams of events. MicroProfile Reactive Messaging makes it easy to write and configure your application to send, receive, and process the events efficiently.

Asynchronous messaging between microservices

Asynchronous communication between microservices can be used to build reactive and responsive applications. By decoupling the requests sent by a microservice from the responses that it receives, the microservice is not blocked from performing other tasks while waiting for the requested data to become available. Imagine asynchronous communication as a restaurant. A waiter might come to your table and take your order. While you are waiting for your food to be prepared, that waiter serves other tables and takes their orders too. When your food is ready, the waiter brings your food to the table and then continues to serve the other tables. If the waiter were to operate synchronously, they must take your order and then wait until they deliver your food before serving any other tables. In microservices, a request call from a REST client to another microservice can be time-consuming because the network might be slow, or the other service might be overwhelmed with requests and can’t respond quickly. But in an asynchronous system, the microservice sends a request to another microservice and continues to send other calls and to receive and process other responses until it receives a response to the original request.

What is MicroProfile Reactive Messaging?

MicroProfile Reactive Messaging provides an easy way to asynchronously send, receive, and process messages that are received as continuous streams of events. You simply annotate application beans' methods and Open Liberty converts the annotated methods to reactive streams-compatible publishers, subscribers, and processors and connects them up to each other. MicroProfile Reactive Messaging provides a Connector API so that your methods can be connected to external messaging systems that produce and consume the streams of events, such as Apache Kafka.

The application in this guide consists of two microservices, system and inventory. Every 15 seconds, the system microservice calculates and publishes an event that contains its current average system load. The inventory microservice subscribes to that information so that it can keep an updated list of all the systems and their current system loads. The current inventory of systems can be accessed via the /systems REST endpoint. You’ll create the system and inventory microservices using MicroProfile Reactive Messaging.

Reactive system inventory

Additional prerequisites

You need to have Docker installed. For installation instructions, refer to the official Docker documentation. You will build and run the microservices in Docker containers. An installation of Apache Kafka is provided in another Docker container.

Getting started

The fastest way to work through this guide is to clone the Git repository and use the projects that are provided inside:

git clone https://github.com/openliberty/guide-microprofile-reactive-messaging.git
cd guide-microprofile-reactive-messaging

The start directory contains the starting project that you will build upon.

The finish directory contains the finished project that you will build.

Before you begin, make sure you have all the necessary prerequisites.

Creating the producer in the system microservice

Navigate to the start directory to begin.

The system microservice is the producer of the messages that are published to the Kafka messaging system as a stream of events. Every 15 seconds, the system microservice publishes an event that contains its calculation of the average system load (its CPU usage) for the last minute.

Create the SystemService class.
system/src/main/java/io/openliberty/guides/system/SystemService.java

SystemService.java

 1// tag::copyright[]
 2/*******************************************************************************
 3 * Copyright (c) 2020, 2024 IBM Corporation and others.
 4 * All rights reserved. This program and the accompanying materials
 5 * are made available under the terms of the Eclipse Public License 2.0
 6 * which accompanies this distribution, and is available at
 7 * http://www.eclipse.org/legal/epl-2.0/
 8 *
 9 * SPDX-License-Identifier: EPL-2.0
10 *******************************************************************************/
11// end::copyright[]
12package io.openliberty.guides.system;
13
14import java.lang.management.ManagementFactory;
15import java.lang.management.OperatingSystemMXBean;
16import java.net.InetAddress;
17import java.net.UnknownHostException;
18import java.util.concurrent.TimeUnit;
19
20import jakarta.enterprise.context.ApplicationScoped;
21
22import org.eclipse.microprofile.reactive.messaging.Outgoing;
23import org.reactivestreams.Publisher;
24
25import io.openliberty.guides.models.SystemLoad;
26import io.reactivex.rxjava3.core.Flowable;
27
28@ApplicationScoped
29public class SystemService {
30
31    private static final OperatingSystemMXBean OS_MEAN =
32            ManagementFactory.getOperatingSystemMXBean();
33    private static String hostname = null;
34
35    private static String getHostname() {
36        if (hostname == null) {
37            try {
38                return InetAddress.getLocalHost().getHostName();
39            } catch (UnknownHostException e) {
40                return System.getenv("HOSTNAME");
41            }
42        }
43        return hostname;
44    }
45
46    // tag::sendSystemLoad[]
47    // tag::publishSystemLoad[]
48    @Outgoing("systemLoad")
49    // end::publishSystemLoad[]
50    public Publisher<SystemLoad> sendSystemLoad() {
51        // tag::flowableInterval[]
52        return Flowable.interval(15, TimeUnit.SECONDS)
53                .map((interval -> new SystemLoad(getHostname(),
54                Double.valueOf(OS_MEAN.getSystemLoadAverage()))));
55        // end::flowableInterval[]
56    }
57    // end::sendSystemLoad[]
58
59}

system/microprofile-config.properties

 1# Kafka connection details
 2# tag::kafkaConfig[]
 3mp.messaging.connector.liberty-kafka.bootstrap.servers=kafka:9092
 4# end::kafkaConfig[]
 5
 6# systemLoad stream
 7# tag::systemLoad[]
 8# tag::kafka1[]
 9mp.messaging.outgoing.systemLoad.connector=liberty-kafka
10# end::kafka1[]
11# tag::topic1[]
12mp.messaging.outgoing.systemLoad.topic=system.load
13# end::topic1[]
14# tag::serializer1[]
15mp.messaging.outgoing.systemLoad.key.serializer=org.apache.kafka.common.serialization.StringSerializer
16# end::serializer1[]
17# tag::serializerVal1[]
18mp.messaging.outgoing.systemLoad.value.serializer=io.openliberty.guides.models.SystemLoad$SystemLoadSerializer
19# end::serializerVal1[]
20# end::systemLoad[]

The SystemService class contains a Publisher method that is called sendSystemLoad(), which calculates and returns the average system load. The @Outgoing annotation on the sendSystemLoad() method indicates that the method publishes its calculation as a message on a topic in the Kafka messaging system. The Flowable.interval() method from rxJava is used to set the frequency of how often the system service publishes the calculation to the event stream.

The messages are transported between the service and the Kafka messaging system through a channel called systemLoad. The name of the channel to use is set in the @Outgoing("systemLoad") annotation. Later in the guide, you will configure the service so that any messages sent by the system service through the systemLoad channel are published on a topic called system.load, as shown in the following diagram:

Reactive system publisher

Creating the consumer in the inventory microservice

The inventory microservice records in its inventory the average system load information that it received from potentially multiple instances of the system service.

Create the InventoryResource class.
inventory/src/main/java/io/openliberty/guides/inventory/InventoryResource.java

InventoryResource.java

  1// tag::copyright[]
  2/*******************************************************************************
  3 * Copyright (c) 2020, 2024 IBM Corporation and others.
  4 * All rights reserved. This program and the accompanying materials
  5 * are made available under the terms of the Eclipse Public License 2.0
  6 * which accompanies this distribution, and is available at
  7 * http://www.eclipse.org/legal/epl-2.0/
  8 *
  9 * SPDX-License-Identifier: EPL-2.0
 10 *******************************************************************************/
 11// end::copyright[]
 12package io.openliberty.guides.inventory;
 13
 14import java.util.List;
 15import java.util.Optional;
 16import java.util.Properties;
 17import java.util.logging.Logger;
 18import java.util.stream.Collectors;
 19
 20import jakarta.enterprise.context.ApplicationScoped;
 21import jakarta.inject.Inject;
 22import jakarta.ws.rs.DELETE;
 23import jakarta.ws.rs.GET;
 24import jakarta.ws.rs.Path;
 25import jakarta.ws.rs.PathParam;
 26import jakarta.ws.rs.Produces;
 27import jakarta.ws.rs.core.MediaType;
 28import jakarta.ws.rs.core.Response;
 29
 30import org.eclipse.microprofile.reactive.messaging.Incoming;
 31
 32import io.openliberty.guides.models.SystemLoad;
 33
 34@ApplicationScoped
 35//tag::inventoryEndPoint[]
 36@Path("/inventory")
 37//end::inventoryEndPoint[]
 38public class InventoryResource {
 39
 40    private static Logger logger = Logger.getLogger(InventoryResource.class.getName());
 41
 42    @Inject
 43    private InventoryManager manager;
 44
 45    @GET
 46    @Path("/systems")
 47    @Produces(MediaType.APPLICATION_JSON)
 48    public Response getSystems() {
 49        List<Properties> systems = manager.getSystems()
 50                .values()
 51                .stream()
 52                .collect(Collectors.toList());
 53        return Response
 54                .status(Response.Status.OK)
 55                .entity(systems)
 56                .build();
 57    }
 58
 59    @GET
 60    @Path("/systems/{hostname}")
 61    @Produces(MediaType.APPLICATION_JSON)
 62    public Response getSystem(@PathParam("hostname") String hostname) {
 63        Optional<Properties> system = manager.getSystem(hostname);
 64        if (system.isPresent()) {
 65            return Response
 66                    .status(Response.Status.OK)
 67                    .entity(system)
 68                    .build();
 69        }
 70        return Response
 71                .status(Response.Status.NOT_FOUND)
 72                .entity("hostname does not exist.")
 73                .build();
 74    }
 75
 76    @DELETE
 77    @Produces(MediaType.APPLICATION_JSON)
 78    public Response resetSystems() {
 79        manager.resetSystems();
 80        return Response
 81                .status(Response.Status.OK)
 82                .build();
 83    }
 84
 85    // tag::updateStatus[]
 86    // tag::systemLoad[]
 87    @Incoming("systemLoad")
 88    // end::systemLoad[]
 89    public void updateStatus(SystemLoad sl)  {
 90        String hostname = sl.hostname;
 91        if (manager.getSystem(hostname).isPresent()) {
 92            manager.updateCpuStatus(hostname, sl.loadAverage);
 93            logger.info("Host " + hostname + " was updated: " + sl);
 94        } else {
 95            manager.addSystem(hostname, sl.loadAverage);
 96            logger.info("Host " + hostname + " was added: " + sl);
 97        }
 98    }
 99    // end::updateStatus[]
100}

inventory/microprofile-config.properties

 1# Kafka connection details
 2# tag::kafkaConfig[]
 3mp.messaging.connector.liberty-kafka.bootstrap.servers=kafka:9092
 4# end::kafkaConfig[]
 5
 6# systemLoad stream
 7# tag::systemLoad[]
 8# tag::kafka1[]
 9mp.messaging.incoming.systemLoad.connector=liberty-kafka
10# end::kafka1[]
11# tag::topic1[]
12mp.messaging.incoming.systemLoad.topic=system.load
13# end::topic1[]
14# tag::deserializer1[]
15mp.messaging.incoming.systemLoad.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
16# end::deserializer1[]
17# tag::deserializerVal1[]
18mp.messaging.incoming.systemLoad.value.deserializer=io.openliberty.guides.models.SystemLoad$SystemLoadDeserializer
19# end::deserializerVal1[]
20# tag::group1[]
21mp.messaging.incoming.systemLoad.group.id=system-load-status
22# end::group1[]
23# end::systemLoad[]

The inventory microservice receives the message from the system microservice over the @Incoming("systemLoad") channel. The properties of this channel are defined in the microprofile-config.properties file. The inventory microservice is also a RESTful service that is served at the /inventory endpoint.

The InventoryResource class contains a method called updateStatus(), which receives the message that contains the average system load and updates its existing inventory of systems and their average system load. The @Incoming("systemLoad") annotation on the updateStatus() method indicates that the method retrieves the average system load information by connecting to the channel called systemLoad. Later in the guide, you will configure the service so that any messages sent by the system service through the systemLoad channel are retrieved from a topic called system.load, as shown in the following diagram:

Reactive system inventory detail

Configuring the MicroProfile Reactive Messaging connectors for Kafka

The system and inventory services exchange messages with the external messaging system through a channel. The MicroProfile Reactive Messaging Connector API makes it easy to connect each service to the channel. You just need to add configuration keys in a properties file for each of the services. These configuration keys define properties such as the name of the channel and the topic in the Kafka messaging system. Open Liberty includes the liberty-kafka connector for sending and receiving messages from Apache Kafka.

The system and inventory microservices each have a MicroProfile Config properties file to define the properties of their outgoing and incoming streams.

Create the system/microprofile-config.properties file.
system/src/main/resources/META-INF/microprofile-config.properties

system/microprofile-config.properties

 1# Kafka connection details
 2# tag::kafkaConfig[]
 3mp.messaging.connector.liberty-kafka.bootstrap.servers=kafka:9092
 4# end::kafkaConfig[]
 5
 6# systemLoad stream
 7# tag::systemLoad[]
 8# tag::kafka1[]
 9mp.messaging.outgoing.systemLoad.connector=liberty-kafka
10# end::kafka1[]
11# tag::topic1[]
12mp.messaging.outgoing.systemLoad.topic=system.load
13# end::topic1[]
14# tag::serializer1[]
15mp.messaging.outgoing.systemLoad.key.serializer=org.apache.kafka.common.serialization.StringSerializer
16# end::serializer1[]
17# tag::serializerVal1[]
18mp.messaging.outgoing.systemLoad.value.serializer=io.openliberty.guides.models.SystemLoad$SystemLoadSerializer
19# end::serializerVal1[]
20# end::systemLoad[]

The mp.messaging.connector.liberty-kafka.bootstrap.servers property configures the hostname and port for connecting to the Kafka server. The system microservice uses an outgoing connector to send messages through the systemLoad channel to the system.load topic in the Kafka message broker so that the inventory microservices can consume the messages. The key.serializer and value.serializer properties characterize how to serialize the messages. The SystemLoadSerializer class implements the logic for turning a SystemLoad object into JSON and is configured as the value.serializer.

The inventory microservice uses a similar microprofile-config.properties configuration to define its required incoming stream.

Create the inventory/microprofile-config.properties file.
inventory/src/main/resources/META-INF/microprofile-config.properties

inventory/microprofile-config.properties

 1# Kafka connection details
 2# tag::kafkaConfig[]
 3mp.messaging.connector.liberty-kafka.bootstrap.servers=kafka:9092
 4# end::kafkaConfig[]
 5
 6# systemLoad stream
 7# tag::systemLoad[]
 8# tag::kafka1[]
 9mp.messaging.incoming.systemLoad.connector=liberty-kafka
10# end::kafka1[]
11# tag::topic1[]
12mp.messaging.incoming.systemLoad.topic=system.load
13# end::topic1[]
14# tag::deserializer1[]
15mp.messaging.incoming.systemLoad.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
16# end::deserializer1[]
17# tag::deserializerVal1[]
18mp.messaging.incoming.systemLoad.value.deserializer=io.openliberty.guides.models.SystemLoad$SystemLoadDeserializer
19# end::deserializerVal1[]
20# tag::group1[]
21mp.messaging.incoming.systemLoad.group.id=system-load-status
22# end::group1[]
23# end::systemLoad[]

The inventory microservice uses an incoming connector to receive messages through the systemLoad channel. The messages were published by the system microservice to the system.load topic in the Kafka message broker. The key.deserializer and value.deserializer properties define how to deserialize the messages. The SystemLoadDeserializer class implements the logic for turning JSON into a SystemLoad object and is configured as the value.deserializer. The group.id property defines a unique name for the consumer group. A consumer group is a collection of consumers who share a common identifier for the group. You can also view a consumer group as the various machines that ingest from the Kafka topics. All of these properties are required by the Apache Kafka Producer Configs and Apache Kafka Consumer Configs.

Configuring Liberty

To run the services, the Open Liberty on which each service runs needs to be correctly configured. Relevant features, including the MicroProfile Reactive Messaging feature, must be enabled for the system and inventory services.

Create the system/server.xml configuration file.
system/src/main/liberty/config/server.xml

server.xml

 1<server description="System Service">
 2
 3  <featureManager>
 4    <feature>cdi-4.0</feature>
 5    <feature>concurrent-3.0</feature>
 6    <feature>jsonb-3.0</feature>
 7    <feature>mpHealth-4.0</feature>
 8    <feature>mpConfig-3.1</feature>
 9    <!-- tag::featureMP[] -->
10    <feature>mpReactiveMessaging-3.0</feature>
11    <!-- end::featureMP[] -->
12  </featureManager>
13
14  <variable name="http.port" defaultValue="9083"/>
15  <variable name="https.port" defaultValue="9446"/>
16
17  <httpEndpoint host="*" httpPort="${http.port}"
18      httpsPort="${https.port}" id="defaultHttpEndpoint"/>
19
20  <logging consoleLogLevel="INFO"/>
21  <webApplication location="system.war" contextRoot="/"/>
22</server>

server.xml

 1<server description="Inventory Service">
 2
 3  <featureManager>
 4    <feature>restfulWS-3.1</feature>
 5    <feature>cdi-4.0</feature>
 6    <feature>concurrent-3.0</feature>
 7    <feature>jsonb-3.0</feature>
 8    <feature>mpHealth-4.0</feature>
 9    <feature>mpConfig-3.1</feature>
10    <feature>mpReactiveMessaging-3.0</feature>
11  </featureManager>
12
13  <variable name="http.port" defaultValue="9085"/>
14  <variable name="https.port" defaultValue="9448"/>
15
16  <httpEndpoint host="*" httpPort="${http.port}" httpsPort="${https.port}" id="defaultHttpEndpoint"/>
17
18  <logging consoleLogLevel="INFO"/>
19  <webApplication location="inventory.war" contextRoot="/"/>
20</server>

The server.xml file is already configured for the inventory microservice.

Building and running the application

Build the system and inventory microservices using Maven and then run them in Docker containers.

Create the Maven configuration file.
system/pom.xml

pom.xml

  1<?xml version='1.0' encoding='utf-8'?>
  2<project xmlns="http://maven.apache.org/POM/4.0.0"
  3    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5    <modelVersion>4.0.0</modelVersion>
  6
  7    <groupId>io.openliberty.guides</groupId>
  8    <artifactId>system</artifactId>
  9    <version>1.0-SNAPSHOT</version>
 10    <packaging>war</packaging>
 11
 12    <properties>
 13        <maven.compiler.source>11</maven.compiler.source>
 14        <maven.compiler.target>11</maven.compiler.target>
 15        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 16        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 17        <!-- Liberty configuration -->
 18        <liberty.var.http.port>9083</liberty.var.http.port>
 19        <liberty.var.https.port>9446</liberty.var.https.port>
 20    </properties>
 21
 22    <dependencies>
 23        <!-- Provided dependencies -->
 24        <dependency>
 25            <groupId>jakarta.platform</groupId>
 26            <artifactId>jakarta.jakartaee-api</artifactId>
 27            <version>10.0.0</version>
 28            <scope>provided</scope>
 29        </dependency>
 30        <dependency>
 31            <groupId>org.eclipse.microprofile</groupId>
 32            <artifactId>microprofile</artifactId>
 33            <version>6.1</version>
 34            <type>pom</type>
 35            <scope>provided</scope>
 36        </dependency>
 37        <!-- tag::reactiveMessaging[] -->
 38        <dependency>
 39            <groupId>org.eclipse.microprofile.reactive.messaging</groupId>
 40            <artifactId>microprofile-reactive-messaging-api</artifactId>
 41            <version>3.0</version>
 42            <scope>provided</scope>
 43        </dependency>
 44        <!-- end::reactiveMessaging[] -->
 45        <!-- Required dependencies -->
 46        <dependency>
 47            <groupId>io.openliberty.guides</groupId>
 48            <artifactId>models</artifactId>
 49            <version>1.0-SNAPSHOT</version>
 50        </dependency>
 51        <!-- tag::kafka[] -->
 52        <dependency>
 53            <groupId>org.apache.kafka</groupId>
 54            <artifactId>kafka-clients</artifactId>
 55            <version>3.8.1</version>
 56        </dependency>
 57        <!-- end::kafka[] -->
 58        <!-- tag::rxjava[] -->
 59        <dependency>
 60            <groupId>io.reactivex.rxjava3</groupId>
 61            <artifactId>rxjava</artifactId>
 62            <version>3.1.9</version>
 63        </dependency>
 64        <!-- end::rxjava[] -->
 65        <dependency>
 66            <groupId>org.slf4j</groupId>
 67            <artifactId>slf4j-api</artifactId>
 68            <version>2.0.16</version>
 69        </dependency>
 70        <dependency>
 71            <groupId>org.slf4j</groupId>
 72            <artifactId>slf4j-simple</artifactId>
 73            <version>2.0.16</version>
 74        </dependency>
 75        <!-- For tests -->
 76        <dependency>
 77            <groupId>org.testcontainers</groupId>
 78            <artifactId>kafka</artifactId>
 79            <version>1.20.3</version>
 80            <scope>test</scope>
 81        </dependency>
 82        <dependency>
 83            <groupId>org.junit.jupiter</groupId>
 84            <artifactId>junit-jupiter</artifactId>
 85            <version>5.11.3</version>
 86            <scope>test</scope>
 87        </dependency>
 88        <dependency>
 89            <groupId>org.testcontainers</groupId>
 90            <artifactId>junit-jupiter</artifactId>
 91            <version>1.20.3</version>
 92            <scope>test</scope>
 93        </dependency>
 94    </dependencies>
 95
 96    <build>
 97        <finalName>${project.artifactId}</finalName>
 98        <plugins>
 99            <plugin>
100                <groupId>org.apache.maven.plugins</groupId>
101                <artifactId>maven-war-plugin</artifactId>
102                <version>3.4.0</version>
103                <configuration>
104                    <packagingExcludes>pom.xml</packagingExcludes>
105                </configuration>
106            </plugin>
107
108            <!-- Liberty plugin -->
109            <plugin>
110                <groupId>io.openliberty.tools</groupId>
111                <artifactId>liberty-maven-plugin</artifactId>
112                <version>3.11.1</version>
113                <configuration>
114                    <!-- devc config -->
115                    <containerRunOpts>
116                        -p 9085:9085
117                        --network=reactive-app
118                    </containerRunOpts>
119                </configuration>
120            </plugin>
121
122            <!-- Plugin to run unit tests -->
123            <plugin>
124                <groupId>org.apache.maven.plugins</groupId>
125                <artifactId>maven-surefire-plugin</artifactId>
126                <version>3.5.2</version>
127            </plugin>
128
129            <!-- Plugin to run integration tests -->
130            <plugin>
131                <groupId>org.apache.maven.plugins</groupId>
132                <artifactId>maven-failsafe-plugin</artifactId>
133                <version>3.5.2</version>
134                <executions>
135                    <execution>
136                        <id>integration-test</id>
137                        <goals>
138                            <goal>integration-test</goal>
139                        </goals>
140                        <configuration>
141                            <trimStackTrace>false</trimStackTrace>
142                        </configuration>
143                    </execution>
144                    <execution>
145                        <id>verify</id>
146                        <goals>
147                            <goal>verify</goal>
148                        </goals>
149                    </execution>
150                </executions>
151            </plugin>
152        </plugins>
153    </build>
154</project>

The pom.xml file lists the microprofile-reactive-messaging-api, kafka-clients, and rxjava dependencies.

The microprofile-reactive-messaging-api dependency is needed to enable the use of MicroProfile Reactive Messaging API. The kafka-clients dependency is added because the application needs a Kafka client to connect to the Kafka broker. The rxjava dependency is used for creating events at regular intervals.

Start your Docker environment. Dockerfiles are provided for you to use.

To build the application, run the Maven install and package goals from the command line in the start directory:

mvn -pl models install
mvn package

Run the following commands to containerize the microservices:

docker build -t system:1.0-SNAPSHOT system/.
docker build -t inventory:1.0-SNAPSHOT inventory/.

Next, use the provided script to start the application in Docker containers. The script creates a network for the containers to communicate with each other. It also creates containers for Kafka and the microservices in the project. For simplicity, the script starts one instance of the system service.

WINDOWS

MAC

LINUX

.\scripts\startContainers.bat
./scripts/startContainers.sh

Testing the application

The application might take some time to become available. After the application is up and running, you can access it by making a GET request to the /systems endpoint of the inventory service.

Visit the http://localhost:9085/health URL to confirm that the inventory microservice is up and running.

When both the liveness and readiness health checks are up, go to the http://localhost:9085/inventory/systems URL to access the inventory microservice. You see the CPU systemLoad property for all the systems:

{
   "hostname":"30bec2b63a96",
   "systemLoad":2.25927734375
}

You can revisit the http://localhost:9085/inventory/systems URL after a while, and you will notice the CPU systemLoad property for the systems changed.

You can use the http://localhost:9085/inventory/systems/{hostname} URL to see the CPU systemLoad property for one particular system.

In the following example, the 30bec2b63a96 value is the hostname. If you go to the http://localhost:9085/inventory/systems/30bec2b63a96 URL, you can see the CPU systemLoad property only for the 30bec2b63a96 hostname:

{
   "hostname":"30bec2b63a96",
   "systemLoad":2.25927734375
}

Tearing down the environment

Run the following script to stop the application:

WINDOWS

MAC

LINUX

.\scripts\stopContainers.bat
./scripts/stopContainers.sh

Great work! You’re done!

You just developed a reactive Java application using MicroProfile Reactive Messaging, Open Liberty, and Kafka.

Guide Attribution

Creating reactive Java microservices by Open Liberty is licensed under CC BY-ND 4.0

Copy file contents
Copied to clipboard

Prerequisites:

Nice work! Where to next?

What did you think of this guide?

Extreme Dislike Dislike Like Extreme Like

What could make this guide better?

Raise an issue to share feedback

Create a pull request to contribute to this guide

Need help?

Ask a question on Stack Overflow

Like Open Liberty? Star our repo on GitHub.

Star