Update for 3.5.1 staging

Author: vietj

amqp-bridge-examples/pom.xml

@@ -6,7 +6,7 @@
 
   <groupId>io.vertx</groupId>
   <artifactId>amqp-bridge-examples</artifactId>
-  <version>3.5.0</version>
+  <version>3.5.1</version>
 
   <dependencies>
     <!-- primary deps -->
@@ -59,7 +59,7 @@
       <repositories>
         <repository>
           <id>staging</id>
-          <url>https://oss.sonatype.org/content/repositories/iovertx-3720/</url>
+          <url>https://oss.sonatype.org/content/repositories/iovertx-3742/</url>
         </repository>
       </repositories>
     </profile>

camel-bridge-examples/README.adoc

@@ -25,7 +25,7 @@ Launch it by running the `main` method in your IDE or, after having build the pr
 
 
 ----
-java -jar target/camel-bridge-examples-3.5.0.jar run io.vertx.example.camel.feed.FeedExample
+java -jar target/camel-bridge-examples-3.5.1.jar run io.vertx.example.camel.feed.FeedExample
 ----
 
 == RMI example
@@ -45,7 +45,7 @@ This example demonstrates:
 Launch it by running the `main` method in your IDE , after having build the project with `mvn clean package`, with:
 
 ----
-java -jar target/camel-bridge-examples-3.5.0.jar run io.vertx.example.camel.rmi.RMIExample
+java -jar target/camel-bridge-examples-3.5.1.jar run io.vertx.example.camel.rmi.RMIExample
 ----
 
 Then open your browser to: `http://localhost:8080/?name=world`

camel-bridge-examples/pom.xml

@@ -6,7 +6,7 @@
 
   <groupId>io.vertx</groupId>
   <artifactId>camel-bridge-examples</artifactId>
-  <version>3.5.0</version>
+  <version>3.5.1</version>
 
   <dependencies>
     <dependency>
@@ -101,7 +101,7 @@
       <repositories>
         <repository>
           <id>staging</id>
-          <url>https://oss.sonatype.org/content/repositories/iovertx-3720/</url>
+          <url>https://oss.sonatype.org/content/repositories/iovertx-3742/</url>
         </repository>
       </repositories>
     </profile>

circuit-breaker-examples/pom.xml

@@ -6,7 +6,7 @@
 
 	<groupId>io.vertx</groupId>
 	<artifactId>circuit-breaker-examples</artifactId>
-	<version>3.5.0</version>
+	<version>3.5.1</version>
 
 	<build>
 		<plugins>
@@ -52,7 +52,7 @@
 			<repositories>
 				<repository>
 					<id>staging</id>
-					<url>https://oss.sonatype.org/content/repositories/iovertx-3720/</url>
+					<url>https://oss.sonatype.org/content/repositories/iovertx-3742/</url>
 				</repository>
 			</repositories>
 		</profile>

consul-examples/pom.xml

@@ -6,7 +6,7 @@
 
   <groupId>io.vertx</groupId>
   <artifactId>consul-examples</artifactId>
-  <version>3.5.0</version>
+  <version>3.5.1</version>
 
   <dependencies>
     <dependency>
@@ -51,7 +51,7 @@
       <repositories>
         <repository>
           <id>staging</id>
-          <url>https://oss.sonatype.org/content/repositories/iovertx-3720/</url>
+          <url>https://oss.sonatype.org/content/repositories/iovertx-3742/</url>
         </repository>
       </repositories>
     </profile>

core-examples/pom.xml

@@ -6,7 +6,7 @@
 
   <groupId>io.vertx</groupId>
   <artifactId>core-examples</artifactId>
-  <version>3.5.0</version>
+  <version>3.5.1</version>
 
   <dependencies>
 
@@ -19,7 +19,7 @@
     <dependency>
       <groupId>io.netty</groupId>
       <artifactId>netty-tcnative-boringssl-static</artifactId>
-      <version>2.0.6.Final</version>
+      <version>2.0.7.Final</version>
     </dependency>
 
     <dependency>
@@ -64,7 +64,7 @@
       <repositories>
         <repository>
           <id>staging</id>
-          <url>https://oss.sonatype.org/content/repositories/iovertx-3720/</url>
+          <url>https://oss.sonatype.org/content/repositories/iovertx-3742/</url>
         </repository>
       </repositories>
     </profile>

core-examples/src/main/groovy/io/vertx/example/core/net/greeter/client.groovy

@@ -0,0 +1,26 @@
+import io.vertx.core.parsetools.RecordParser
+vertx.createNetClient().connect(1234, "localhost", { res ->
+
+  if (res.succeeded()) {
+    def socket = res.result()
+
+    RecordParser.newDelimited("\n", socket).endHandler({ v ->
+      socket.close()
+    }).exceptionHandler({ t ->
+      t.printStackTrace()
+      socket.close()
+    }).handler({ buffer ->
+      def greeting = buffer.toString("UTF-8")
+      println("Net client receiving: ${greeting}")
+    })
+
+    // Now send some data
+    java.util.stream.Stream.of("John", "Joe", "Lisa", "Bill").forEach({ name ->
+      println("Net client sending: ${name}")
+      socket.write(name).write("\n")
+    })
+
+  } else {
+    println("Failed to connect ${res.cause()}")
+  }
+})

core-examples/src/main/groovy/io/vertx/example/core/net/greeter/server.groovy

@@ -0,0 +1,20 @@
+import io.vertx.core.parsetools.RecordParser
+
+vertx.createNetServer().connectHandler({ sock ->
+
+  def parser = RecordParser.newDelimited("\n", sock)
+
+  parser.endHandler({ v ->
+    sock.close()
+  }).exceptionHandler({ t ->
+    t.printStackTrace()
+    sock.close()
+  }).handler({ buffer ->
+    def name = buffer.toString("UTF-8")
+    sock.write("Hello ${name}\n", "UTF-8")
+  })
+
+}).listen(1234)
+
+println("Echo server is now listening")
+

core-examples/src/main/groovy/io/vertx/example/core/net/stream/client.groovy

@@ -0,0 +1,51 @@
+import io.vertx.core.buffer.Buffer
+vertx.createNetClient().connect(1234, "localhost", { ar ->
+  if (ar.succeeded()) {
+
+    def socket = ar.result()
+
+    // Create batch stream for reading and writing
+    def batchStream = new io.vertx.example.core.net.stream.BatchStream(socket, socket)
+
+    // Pause reading data
+    batchStream.pause()
+
+    // Register read stream handler
+    batchStream.handler({ batch ->
+      println("Client Received : ${batch.getRaw().toString()}")
+    }).endHandler({ v ->
+      batchStream.end()
+    }).exceptionHandler({ t ->
+      t.printStackTrace()
+      batchStream.end()
+    })
+
+    // Resume reading data
+    batchStream.resume()
+
+    // JsonObject
+    def jsonObject = [
+      id:java.util.UUID.randomUUID().toString(),
+      name:"Vert.x",
+      timestamp:java.time.Instant.now()
+    ]
+
+    // JsonArray
+    def jsonArray = [
+      java.util.UUID.randomUUID().toString(),
+      "Vert.x",
+      java.time.Instant.now()
+    ]
+
+    // Buffer
+    def buffer = Buffer.buffer("Vert.x is awesome!")
+
+    // Write to socket
+    batchStream.write(new io.vertx.example.core.net.stream.Batch(jsonObject))
+    batchStream.write(new io.vertx.example.core.net.stream.Batch(jsonArray))
+    batchStream.write(new io.vertx.example.core.net.stream.Batch(buffer))
+
+  } else {
+    println("Failed to connect ${ar.cause()}")
+  }
+})

core-examples/src/main/groovy/io/vertx/example/core/net/stream/server.groovy

@@ -0,0 +1,43 @@
+vertx.createNetServer().connectHandler({ socket ->
+
+  // Create batch stream for reading and writing
+  def batchStream = new io.vertx.example.core.net.stream.BatchStream(socket, socket)
+
+  // Pause reading data
+  batchStream.pause()
+
+  // Register read stream handler
+  batchStream.handler({ batch ->
+
+    // Print received batch object from the client
+    println("Server Received : ${batch.getRaw().toString()}")
+
+    // Write back batch object to the client
+    batchStream.write(batch)
+
+    // Check if write queue is full
+    if (batchStream.writeQueueFull()) {
+
+      // Pause reading data
+      batchStream.pause()
+
+      // Called once write queue is ready to accept more data
+      batchStream.drainHandler({ done ->
+
+        // Resume reading data
+        batchStream.resume()
+
+      })
+    }
+  }).endHandler({ v ->
+    batchStream.end()
+  }).exceptionHandler({ t ->
+    t.printStackTrace()
+    batchStream.end()
+  })
+
+  // Resume reading data
+  batchStream.resume()
+
+}).listen(1234)
+println("Batch server is now listening to port : 1234")

core-examples/src/main/js/io/vertx/example/core/net/greeter/client.js

@@ -0,0 +1,26 @@
+var RecordParser = require("vertx-js/record_parser");
+vertx.createNetClient().connect(1234, "localhost", function (res, res_err) {
+
+  if (res_err == null) {
+    var socket = res;
+
+    RecordParser.newDelimited("\n", socket).endHandler(function (v) {
+      socket.close();
+    }).exceptionHandler(function (t) {
+      t.printStackTrace();
+      socket.close();
+    }).handler(function (buffer) {
+      var greeting = buffer.toString("UTF-8");
+      console.log("Net client receiving: " + greeting);
+    });
+
+    // Now send some data
+    Java.type("java.util.stream.Stream").of("John", "Joe", "Lisa", "Bill").forEach(function (name) {
+      console.log("Net client sending: " + name);
+      socket.write(name).write("\n");
+    });
+
+  } else {
+    console.log("Failed to connect " + res_err);
+  }
+});

core-examples/src/main/js/io/vertx/example/core/net/greeter/server.js

@@ -0,0 +1,20 @@
+var RecordParser = require("vertx-js/record_parser");
+
+vertx.createNetServer().connectHandler(function (sock) {
+
+  var parser = RecordParser.newDelimited("\n", sock);
+
+  parser.endHandler(function (v) {
+    sock.close();
+  }).exceptionHandler(function (t) {
+    t.printStackTrace();
+    sock.close();
+  }).handler(function (buffer) {
+    var name = buffer.toString("UTF-8");
+    sock.write("Hello " + name + "\n", "UTF-8");
+  });
+
+}).listen(1234);
+
+console.log("Echo server is now listening");
+

core-examples/src/main/js/io/vertx/example/core/net/stream/client.js

@@ -0,0 +1,51 @@
+var Buffer = require("vertx-js/buffer");
+vertx.createNetClient().connect(1234, "localhost", function (ar, ar_err) {
+  if (ar_err == null) {
+
+    var socket = ar;
+
+    // Create batch stream for reading and writing
+    var batchStream = new (Java.type("io.vertx.example.core.net.stream.BatchStream"))(socket, socket);
+
+    // Pause reading data
+    batchStream.pause();
+
+    // Register read stream handler
+    batchStream.handler(function (batch) {
+      console.log("Client Received : " + batch.getRaw().toString());
+    }).endHandler(function (v) {
+      batchStream.end();
+    }).exceptionHandler(function (t) {
+      t.printStackTrace();
+      batchStream.end();
+    });
+
+    // Resume reading data
+    batchStream.resume();
+
+    // JsonObject
+    var jsonObject = {
+      "id" : Java.type("java.util.UUID").randomUUID().toString(),
+      "name" : "Vert.x",
+      "timestamp" : Java.type("java.time.Instant").now()
+    };
+
+    // JsonArray
+    var jsonArray = [
+      Java.type("java.util.UUID").randomUUID().toString(),
+      "Vert.x",
+      Java.type("java.time.Instant").now()
+    ];
+
+    // Buffer
+    var buffer = Buffer.buffer("Vert.x is awesome!");
+
+    // Write to socket
+    batchStream.write(new (Java.type("io.vertx.example.core.net.stream.Batch"))(jsonObject));
+    batchStream.write(new (Java.type("io.vertx.example.core.net.stream.Batch"))(jsonArray));
+    batchStream.write(new (Java.type("io.vertx.example.core.net.stream.Batch"))(buffer));
+
+  } else {
+    console.log("Failed to connect " + ar_err);
+  }
+});