diff --git a/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/SubscriptionManagerImpl.java b/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/SubscriptionManagerImpl.java index 72f2413972794c3fe0c2c28f4b2ac9dbe715ed1b..343c31939c65575c5b0b224a42f79470cc59ef60 100644 --- a/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/SubscriptionManagerImpl.java +++ b/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/SubscriptionManagerImpl.java @@ -123,11 +123,11 @@ public class SubscriptionManagerImpl implements ISubscriptionManager { } for (String deletedSubscription : deletedTopicSubscriptions) { 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 .getSubscriptionClient(partition, entry.getKey(), deletedSubscription); 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) { LOGGER.error("Error while closing subscription client {}", e.getMessage(), e); } catch (Exception e) {