vertx-event-bus-example-01

https://blog.knoldus.com/event-bus-in-vert-x-how-it-works/ Project Structure SenderVerticle.java public class SenderVerticle extends AbstractVerticle { @Override public void start() throws…

vertx-verticle-example-03

Project Structure pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>zjc.examples</groupId> <artifactId>vertx-verticle-example-03</artifactId> <version>1.0-SNAPSHOT</version>…

vertx-verticle-example-02

Project Structure pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>zjc.examples</groupId> <artifactId>vertx-verticle-example-02</artifactId> <version>1.0-SNAPSHOT</version>…

vertx-verticle-example-01

Project Structure pom.xml <project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>zjc.examples</groupId> <artifactId>vertx-verticle-example-01</artifactId> <version>1.0-SNAPSHOT</version> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>…

webflux-r2dbc-pagination-sort

Project Setup Project Structure Database setup application.properties logging.level.org.springframework.r2dbc=DEBUG spring.r2dbc.url=r2dbc:postgresql://localhost:5432/reactivedb spring.r2dbc.username=postgres spring.r2dbc.password=postgres init.sql DROP TABLE IF…

R2DBC-PostgreSQL-example

Postgresql setup: ConnectionFactory connectionFactory = new PostgresqlConnectionFactory(PostgresqlConnectionConfiguration.builder() .host("localhost") .port(5432) .username("postgres") .password("postgres") .database("reactivedb") .build()); Create db…

RxJava: Basic Guide

Observable and Subscriber http://reactivex.io/RxJava/3.x/javadoc/io/reactivex/rxjava3/core/Observable.htmlhttps://reactivex.io/RxJava/javadoc/rx/Subscriber.html Observable is a class that emits a stream of data or…