eclipse-zenoh
diff --git a/‎.gitignore‎
Lines changed: 1 addition & 0 deletions b/‎.gitignore‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎examples/build.gradle.kts‎
Lines changed: 10 additions & 0 deletions b/‎examples/build.gradle.kts‎
Lines changed: 10 additions & 0 deletions
diff --git a/‎examples/src/main/java/io/zenoh/Config.kt‎
Lines changed: 74 additions & 0 deletions b/‎examples/src/main/java/io/zenoh/Config.kt‎
Lines changed: 74 additions & 0 deletions
diff --git a/‎examples/src/main/java/io/zenoh/QueueHandler.java‎
Lines changed: 33 additions & 0 deletions b/‎examples/src/main/java/io/zenoh/QueueHandler.java‎
Lines changed: 33 additions & 0 deletions
diff --git a/‎examples/src/main/java/io/zenoh/ZDelete.java‎
Lines changed: 80 additions & 8 deletions b/‎examples/src/main/java/io/zenoh/ZDelete.java‎
Lines changed: 80 additions & 8 deletions
@@ -19,3 +19,4 @@
 /examples/build/
 /build/
 /.gradle/
+*/build/
@@ -14,6 +14,7 @@
 
 plugins {
     kotlin("jvm")
+    kotlin("plugin.serialization") version "1.9.0"
 }
 
 kotlin {
@@ -23,17 +24,26 @@ kotlin {
 dependencies {
     implementation(project(":zenoh-java"))
     implementation("commons-net:commons-net:3.9.0")
+    implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.6.0")
+    implementation("info.picocli:picocli:4.7.4")
 }
 
 tasks {
     val examples = listOf(
         "ZDelete",
         "ZGet",
+        "ZGetLiveliness",
+        "ZInfo",
+        "ZLiveliness",
+        "ZPing",
+        "ZPong",
         "ZPub",
         "ZPubThr",
         "ZPut",
         "ZQueryable",
+        "ZScout",
         "ZSub",
+        "ZSubLiveliness",
         "ZSubThr"
     )
 
 
@@ -0,0 +1,74 @@
+//
+// Copyright (c) 2023 ZettaScale Technology
+//
+// This program and the accompanying materials are made available under the
+// terms of the Eclipse Public License 2.0 which is available at
+// http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
+// which is available at https://www.apache.org/licenses/LICENSE-2.0.
+//
+// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
+//
+// Contributors:
+//   ZettaScale Zenoh Team, <[email protected]>
+//
+
+package io.zenoh
+
+import kotlinx.serialization.Serializable
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.encodeToJsonElement
+import kotlin.io.path.Path
+
+@Serializable
+data class ConfigData(
+    @SerialName("connect") var connect: Connect? = null,
+    @SerialName("listen") var listen: Listen? = null,
+    @SerialName("mode") var mode: String? = null,
+    @SerialName("scouting") var scouting: Scouting? = null,
+)
+
+@Serializable
+data class Connect(
+    @SerialName("endpoints") var endpoints: List<String>
+)
+
+@Serializable
+data class Listen(
+    @SerialName("endpoints") var endpoints: List<String>
+)
+
+@Serializable
+data class Scouting(
+    @SerialName("multicast") var multicast: Multicast,
+)
+
+@Serializable
+data class Multicast(
+    @SerialName("enabled") var enabled: Boolean,
+)
+
+internal fun loadConfig(
+    emptyArgs: Boolean,
+    configFile: String?,
+    connectEndpoints: List<String>?,
+    listenEndpoints: List<String>?,
+    noMulticastScouting: Boolean?,
+    mode: String?
+): Config {
+    return if (emptyArgs) {
+        Config.loadDefault()
+    } else {
+        configFile?.let {
+            Config.fromFile(path = Path(it))
+        } ?: run {
+            val connect = connectEndpoints?.let {Connect(it)}
+            val listen = listenEndpoints?.let {Listen(it)}
+            val scouting = noMulticastScouting?.let { Scouting(Multicast(!it)) }
+            val configData = ConfigData(connect, listen, mode, scouting)
+            val jsonConfig = Json.encodeToJsonElement(configData).toString()
+            println(jsonConfig)
+            Config.fromJson(jsonConfig)
+        }
+    }
+}
@@ -0,0 +1,33 @@
+package io.zenoh;
+
+import io.zenoh.handlers.Handler;
+
+import java.util.ArrayDeque;
+
+/**
+ * Sample handler for the sake of the examples.
+ *
+ * A custom handler can be implemented to handle incoming samples, queries or replies for
+ * subscribers, get operations, query operations or queryables.
+ *
+ * The example below shows a queue handler, in which an ArrayDeque is specified as the receiver type.
+ * The function handle will be called everytime an element of type T is received and in our example
+ * implementation, elements are simply enqueued into the queue, which can later be retrieved.
+ */
+class QueueHandler<T extends ZenohType> implements Handler<T, ArrayDeque<T>> {
+
+    final ArrayDeque<T> queue = new ArrayDeque<>();
+
+    @Override
+    public void handle(T t) {
+        queue.add(t);
+    }
+
+    @Override
+    public ArrayDeque<T> receiver() {
+        return queue;
+    }
+
+    @Override
+    public void onClose() {}
+}
@@ -14,17 +14,89 @@
 
 package io.zenoh;
 
-import io.zenoh.exceptions.ZenohException;
+import io.zenoh.exceptions.ZError;
 import io.zenoh.keyexpr.KeyExpr;
+import picocli.CommandLine;
 
-public class ZDelete {
-    public static void main(String[] args) throws ZenohException {
+import java.util.List;
+import java.util.concurrent.Callable;
+
+import static io.zenoh.ConfigKt.loadConfig;
+
+@CommandLine.Command(
+        name = "ZDelete",
+        mixinStandardHelpOptions = true,
+        description = "Zenoh Delete example"
+)
+public class ZDelete implements Callable<Integer> {
+
+    @Override
+    public Integer call() throws ZError {
+        Zenoh.initLogFromEnvOr("error");
         System.out.println("Opening session...");
-        try (Session session = Session.open()) {
-            try (KeyExpr keyExpr = KeyExpr.tryFrom("demo/example/zenoh-java-put")) {
-                System.out.println("Deleting resources matching '" + keyExpr + "'...");
-                session.delete(keyExpr).res();
-            }
+        Config config = loadConfig(emptyArgs, configFile, connect, listen, noMulticastScouting, mode);
+        try (Session session = Zenoh.open(config)) {
+            KeyExpr keyExpr = KeyExpr.tryFrom(key);
+            System.out.println("Deleting resources matching '" + keyExpr + "'...");
+            session.delete(keyExpr);
         }
+        return 0;
+    }
+
+
+    /**
+     * ----- Example CLI arguments and private fields -----
+     */
+
+    private final Boolean emptyArgs;
+
+    ZDelete(Boolean emptyArgs) {
+        this.emptyArgs = emptyArgs;
+    }
+
+    @CommandLine.Option(
+            names = {"-e", "--connect"},
+            description = "Endpoints to connect to.",
+            split = ","
+    )
+    private List<String> connect;
+
+    @CommandLine.Option(
+            names = {"-l", "--listen"},
+            description = "Endpoints to listen on.",
+            split = ","
+    )
+    private List<String> listen;
+
+    @CommandLine.Option(
+            names = {"-c", "--config"},
+            description = "A configuration file."
+    )
+    private String configFile;
+
+    @CommandLine.Option(
+            names = {"-k", "--key"},
+            description = "The key expression to delete [default: demo/example/zenoh-java-delete].",
+            defaultValue = "demo/example/zenoh-java-delete"
+    )
+    private String key;
+
+    @CommandLine.Option(
+            names = {"-m", "--mode"},
+            description = "The session mode. Default: peer. Possible values: [peer, client, router].",
+            defaultValue = "peer"
+    )
+    private String mode;
+
+    @CommandLine.Option(
+            names = {"--no-multicast-scouting"},
+            description = "Disable the multicast-based scouting mechanism.",
+            defaultValue = "false"
+    )
+    private boolean noMulticastScouting;
+
+    public static void main(String[] args) {
+        int exitCode = new CommandLine(new ZDelete(args.length == 0)).execute(args);
+        System.exit(exitCode);
     }
 }