}

        try {
            InetAddress serverAddress = transport.getRemoteAddress().toInetAddress();

            witnessClient.registerForNotifications(shareName, serverAddress, new WitnessNotificationHandler()).thenAccept(registration -> {
                log.info("Registered for witness notifications: share={}, id={}", shareName, registration.getRegistrationId());
            }).exceptionally(error -> {