Fix catches

renovate-bot · Sep 12, 2023 · af96f23 · af96f23
1 parent 079acc4
commit af96f23
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/samples/snippets/src/main/java/pubsub/SubscribeAsyncLimitedConcurrencyExample.java b/samples/snippets/src/main/java/pubsub/SubscribeAsyncLimitedConcurrencyExample.java
@@ -42,8 +42,8 @@
 public class SubscribeAsyncLimitedConcurrencyExample {
   public static void main(String... args) throws Exception {
     // TODO(developer): Replace these variables before running the sample.
-    String projectId = "my-project";
-    String subscriptionId = "my-subscription";
+    String projectId = "ordering-keys-testing";
+    String subscriptionId = "threads-test";
 
     subscribeAsyncLimitedConcurrencyExample(projectId, subscriptionId);
   }
@@ -145,7 +145,8 @@ public static void subscribeAsyncLimitedConcurrencyExample(
     try {
       Thread.sleep(30000);
     } catch (Exception e) {
-
+      System.out.println("Could not sleep: " + e);
+      return;
     }
     printThreads();
 

diff --git a/samples/snippets/src/main/java/pubsub/SubscribeAsyncUnlimitedConcurrencyExample.java b/samples/snippets/src/main/java/pubsub/SubscribeAsyncUnlimitedConcurrencyExample.java
@@ -68,7 +68,8 @@ public static void subscribeAsyncUnlimitedConcurrencyExample(
     try {
       Thread.sleep(30000);
     } catch (Exception e) {
-
+      System.out.println("Could not sleep: " + e);
+      return;
     }
     printThreads();
     for (Subscriber subscriber : subscribers) {