X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/03c30519b11e9772eecdc74f89d350bdecd20361..de273586b4106171a3940ce5ec2c2b3712430c8c:/src/main/java/org/asamk/signal/commands/DaemonCommand.java diff --git a/src/main/java/org/asamk/signal/commands/DaemonCommand.java b/src/main/java/org/asamk/signal/commands/DaemonCommand.java index 19859d45..6ee4f316 100644 --- a/src/main/java/org/asamk/signal/commands/DaemonCommand.java +++ b/src/main/java/org/asamk/signal/commands/DaemonCommand.java @@ -45,7 +45,7 @@ public class DaemonCommand implements MultiLocalCommand { @Override public int handleCommand(final Namespace ns, final Manager m) { - boolean inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json"); + var inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json"); // TODO delete later when "json" variable is removed if (ns.getBoolean("json")) { @@ -61,9 +61,9 @@ public class DaemonCommand implements MultiLocalCommand { busType = DBusConnection.DBusBusType.SESSION; } - try (DBusConnection conn = DBusConnection.getConnection(busType)) { - String objectPath = DbusConfig.getObjectPath(); - Thread t = run(conn, objectPath, m, ignoreAttachments, inJson); + try (var conn = DBusConnection.getConnection(busType)) { + var objectPath = DbusConfig.getObjectPath(); + var t = run(conn, objectPath, m, ignoreAttachments, inJson); conn.requestBusName(DbusConfig.getBusname()); @@ -80,7 +80,7 @@ public class DaemonCommand implements MultiLocalCommand { @Override public int handleCommand(final Namespace ns, final List managers) { - boolean inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json"); + var inJson = ns.get("output") == OutputType.JSON || ns.getBoolean("json"); // TODO delete later when "json" variable is removed if (ns.getBoolean("json")) { @@ -96,17 +96,17 @@ public class DaemonCommand implements MultiLocalCommand { busType = DBusConnection.DBusBusType.SESSION; } - try (DBusConnection conn = DBusConnection.getConnection(busType)) { - List receiveThreads = new ArrayList<>(); - for (Manager m : managers) { - String objectPath = DbusConfig.getObjectPath(m.getUsername()); - Thread thread = run(conn, objectPath, m, ignoreAttachments, inJson); + try (var conn = DBusConnection.getConnection(busType)) { + var receiveThreads = new ArrayList(); + for (var m : managers) { + var objectPath = DbusConfig.getObjectPath(m.getUsername()); + var thread = run(conn, objectPath, m, ignoreAttachments, inJson); receiveThreads.add(thread); } conn.requestBusName(DbusConfig.getBusname()); - for (Thread t : receiveThreads) { + for (var t : receiveThreads) { try { t.join(); } catch (InterruptedException ignored) { @@ -124,7 +124,7 @@ public class DaemonCommand implements MultiLocalCommand { ) throws DBusException { conn.exportObject(objectPath, new DbusSignalImpl(m)); - final Thread thread = new Thread(() -> { + final var thread = new Thread(() -> { while (true) { try { m.receiveMessages(1,