don't use retries, include checkpoints

Author: miparnisari

examples/v1/CallingWatch.java

@@ -35,33 +35,14 @@ public static void main(String[] args) {
         ManagedChannel channel = ManagedChannelBuilder
                 .forTarget(target)
                 .useTransportSecurity() // if not using TLS, replace with .usePlaintext()
-                .disableServiceConfigLookUp()
-                .defaultServiceConfig(Map.of(
-                        "methodConfig", List.of(
-                                Map.of(
-                                        "name",  List.of(
-                                                Map.of(
-                                                        "service", "authzed.api.v1.WatchService",
-                                                        "method", "Watch"
-                                                )
-                                        ),
-                                        "retryPolicy", Map.of(
-                                                "maxAttempts", "5",
-                                                "initialBackoff", "1s",
-                                                "backoffMultiplier", "4.0",
-                                                "maxBackoff", "30s",
-                                                "retryableStatusCodes", List.of("UNAVAILABLE", "INTERNAL")
-                                        )
-                                )
-                        )
-                ))
                 .build();
 
         ZedToken lastZedToken = ZedToken.newBuilder().setToken("").build();
 
         while(true) {
             try {
                 WatchRequest.Builder builder = WatchRequest.newBuilder();
+                builder.addOptionalUpdateKinds(com.authzed.api.v1.WatchKind.WATCH_KIND_INCLUDE_CHECKPOINTS);
 
                 if (!lastZedToken.getToken().isEmpty()) {
                     builder.setOptionalStartCursor(lastZedToken);
@@ -73,21 +54,21 @@ public static void main(String[] args) {
 
                 while (watchStream.hasNext()) {
                     WatchResponse msg = watchStream.next();
-                    System.out.println("Received watch response: " + msg);
+                    if (msg.getUpdatesCount() > 0) {
+                        for (var update : msg.getUpdatesList()) {
+                            System.out.println("Received update: " + update);
+                        }
+                    } else {
+                        System.out.println("No changes made in SpiceDB");
+                    }
 
                     if (!msg.getChangesThrough().getToken().isEmpty()) {
                         lastZedToken = msg.getChangesThrough();
                     }
                 }
-
             } catch (Exception e) {
-                if (e instanceof StatusRuntimeException sre && (sre.getStatus().getCode().equals(Status.UNAVAILABLE.getCode()) ||
-                        sre.getStatus().getCode().equals(Status.INTERNAL.getCode()))) {
-                    // Stream probably got disconnected after inactivity. Retry
-                } else {
-                    System.out.println("Error calling watch: " + e.getMessage());
-                    return;
-                }
+                System.out.println("Error calling watch: " + e.getMessage());
+                return;
             }
         }
     }