Issue-ID: DCAEGEN2-198
Change-Id: I09296ae4d13a0ad442bc139e69c13d19e4be0916
Signed-off-by: Vijay <vv770d@att.com>
log.info("Pending Message Count=" + pendingMsgs);
}
- //closePublisher();
+ closePublisher();
log.info("pub.send invoked - no error");
CommonStartup.oplog.info(String.format("URL:%sTOPIC:%sEvent Published:%s",
ueburl, topic, event));
} catch (IOException | GeneralSecurityException | IllegalArgumentException e) {
log.error("Unable to publish event: {} streamid: {}. Exception: {}", event, streamid, e);
}
+ finally {
+ closePublisher();
+ }
}