From fe1de13a6395ee69d7e602700d9146db6bcda01a Mon Sep 17 00:00:00 2001 From: Jan Lukavsky Date: Tue, 11 Jul 2023 10:38:28 +0200 Subject: [PATCH] [proxima-direct-io-pubsub] rethrow all exceptions in PubSubReader.observe --- .../main/java/cz/o2/proxima/direct/io/pubsub/PubSubReader.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/PubSubReader.java b/direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/PubSubReader.java index 521db825e..7e01a0d2d 100644 --- a/direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/PubSubReader.java +++ b/direct/io-pubsub/module/src/main/java/cz/o2/proxima/direct/io/pubsub/PubSubReader.java @@ -408,8 +408,6 @@ Subscriber newSubscriber(ProjectSubscriptionName subscription, MessageReceiver r if (subscriptionAutoCreate) { try (SubscriptionAdminClient client = SubscriptionAdminClient.create()) { createSubscription(client, subscription); - } catch (IOException ex) { - log.error("Failed to close SubscriptionAdminClient", ex); } catch (Exception ex) { throw new RuntimeException(ex); }