1. it comes with great new features like the GraphQL extension for Vert.x Web.
2. this is the last minor version before Vert.x 4!

Vert.x Web GraphQL

<dependency> <groupId>io.vertxgroupId> <artifactId>vertx-web-graphqlartifactId> <version>3.7.0version> dependency>

compile 'io.vertx:vertx-web-graphql:3.7.0'

// Setup the GraphQL-Java object GraphQL graphQL = setupGraphQLJava(); // Use it to handle requests on a Vert.x Web route  router.route("/graphql").handler(GraphQLHandler.create(graphQL));

• query context customization
• GraphQL-Java data loaders
• batching on POST requests (compatible with the apollo-link-batch-http transport)

Vert.x Cassandra Client

Object mapper support

<dependency> <groupId>com.datastax.cassandragroupId> <artifactId>cassandra-driver-mappingartifactId> <version>3.7.1version> dependency>

@Table(keyspace = "test", name = "users") class User { @PartitionKey String name; // ... other fields and methods  }

VertxMappingManager manager = VertxMappingManager.create(cassandraClient); VertxMapper mapper = manager.mapper(User.class, vertx); mapper.save(new User("john", hander -> {}));

Collector API

// Create a collector projecting a row set to a string in the form (last_name_1,last_name_2,...) Collector collector = Collectors.mapping( row -> row.getString("last_name"), Collectors.joining(",", "(", ")") ); // Run the query with the collector client.execute("SELECT * FROM users", collector, ar -> { if (ar.succeeded()) { // Result in the form (last_name_1,last_name_2,...) String result = ar.result(); } else { System.out.println("Failure: " + ar.cause().getMessage()); } });

Cursor API

resultSet.several(30, ar -> { if (ar.succeeded()) { List result = ar.result(); } else { System.out.println("Failure: " + ar.cause().getMessage()); } });

Client lifecyle

CassandraClientOptions options = new CassandraClientOptions() .addContactPoint("node1.address") .addContactPoint("node2.address") .addContactPoint("node3.address") .setKeyspace("my_keyspace"); CassandraClient sharedClient = CassandraClient.createShared(vertx, "sharedClientName", options); // Start sending requests to Cassandra with the client instance

// Disconnects only if this is the last running instance of the shared client sharedClient.close();

Vert.x Redis Client

Redis .createClient(vertx, inetSocketAddress(7006, "127.0.0.1")) .connect(create -> { final Redis redis = create.result(); redis.send(Request.cmd(Command.PING), send -> { // ... should reply with PONG }); });

• Single server
• HA mode
• Cluster mode

• streams
• hyperloglog
• any extension module

RedisAPI redis = RedisAPI.api(client); redis.set(Arrays.asList("key1", "value1"), set -> { // ... });

Vert.x AMQP Client

• Connecting to an AMQP broker or router - SASL and TLS connections are supported
• Consuming message from a queue or a topic
• Sending messages to a queue or a topic
• Checking acknowledgement for sent messages

<dependency> <groupId>io.vertxgroupId> <artifactId>vertx-amqp-clientartifactId> <version>3.7.0version> dependency>

compile 'io.vertx:vertx-amqp-client:3.7.0'

AmqpClientOptions options = new AmqpClientOptions() .setHost("localhost") .setPort(5672) .setUsername("user") .setPassword("secret"); AmqpClient client = AmqpClient.create(vertx, options); client.connect(ar -> { if (ar.failed()) { System.out.println("Unable to connect to the broker"); } else { System.out.println("Connection succeeded"); AmqpConnection connection = ar.result(); // You can create receivers and senders connection.createReceiver("my-queue", msg -> { // called on every received messages System.out.println("Received " + msg.bodyAsString()); }, done -> { if (done.failed()) { System.out.println("Unable to create receiver"); } else { AmqpReceiver receiver = done.result(); } } ); connection.createSender("my-queue", done -> { if (done.failed()) { System.out.println("Unable to create a sender"); } else { AmqpSender sender = done.result(); sender.send(AmqpMessage.create().withBody("hello").build()); } }); } });

Stream pipes

• read stream pause/resume
• write stream termination
• stream failures handling
• asynchronous result upon streaming completion

readStream.pipeTo(writeStream);

readStream.pipeTo(writeStream, ar -> { if (ar.succeeded()) { System.out.println("done"); } else { System.out.println("failed " + ar.cause()); } });

// The read stream will be paused until the pipe is used Pipe pipe = readStream.pipe(); getAsyncPipe(ar -> { if (ar.succeeded()) { pipe.to(writeStream); } else { pipe.close(); } });

Kafka admin client

Properties config = new Properties(); config.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "my-kafka-broker:9092"); KafkaAdminClient adminClient = KafkaAdminClient.create(vertx, config);

• create and delete topics
• list all the topics
• describe topics for getting information about leader partition, follower replicas and ISR (in-sync replicas) list
• alter topics configuration
• list all consumer groups
• describe consumer groups for getting information like the state, the coordinator host, consumers per topics and so on

And more…

• Shared data structures available in local-only mode even when Vert.x is clustered
• JSON decoding without prior knowledge of the structure (object, array, string, …etc)
• Infinispan Cluster Manager upgraded to Infinispan 9.4.10.Final
• And obviously we have the usual bug fixes!

Finally

• NPM
• Bower
• WebJars