Skip to content
Snippets Groups Projects
Commit bf410dbd authored by Alok Joshi's avatar Alok Joshi
Browse files

change info message

parent 277dcbf4
No related branches found
No related tags found
1 merge request!364Close deleted subscriptions
Pipeline #175360 failed
...@@ -123,11 +123,11 @@ public class SubscriptionManagerImpl implements ISubscriptionManager { ...@@ -123,11 +123,11 @@ public class SubscriptionManagerImpl implements ISubscriptionManager {
} }
for (String deletedSubscription : deletedTopicSubscriptions) { for (String deletedSubscription : deletedTopicSubscriptions) {
try { try {
LOGGER.info("Cleanup => found deleted subscription " + deletedSubscription + " for topic " + entry.getKey()); LOGGER.info("Found deleted subscription " + deletedSubscription + " for topic " + entry.getKey());
SubscriptionClient subscriptionClient = this.subscriptionClientFactory SubscriptionClient subscriptionClient = this.subscriptionClientFactory
.getSubscriptionClient(partition, entry.getKey(), deletedSubscription); .getSubscriptionClient(partition, entry.getKey(), deletedSubscription);
subscriptionClient.close(); subscriptionClient.close();
LOGGER.info("Cleanup => closed deleted subscription " + deletedSubscription + " for topic " + entry.getKey()); LOGGER.info("Closed deleted subscription " + deletedSubscription + " for topic " + entry.getKey());
} catch (InterruptedException | ServiceBusException e) { } catch (InterruptedException | ServiceBusException e) {
LOGGER.error("Error while closing subscription client {}", e.getMessage(), e); LOGGER.error("Error while closing subscription client {}", e.getMessage(), e);
} catch (Exception e) { } catch (Exception e) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment