aboutsummaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
authorVijay <vv770d@att.com>2017-11-08 13:12:26 +0000
committerVijay <vv770d@att.com>2017-11-08 13:12:48 +0000
commit1451cc1cc91927f38648fb36e2c0f20393f27c84 (patch)
tree9800f3c4a0297855ddf91731fa5b6f20faf32f66 /src/main
parent72e1ebb4960dcbf2262cd89b25d43af5d957fe1b (diff)
fix memory leak for vescollectorv1.1.4v1.1.01.0.0-ONAP1.0.0-Amsterdam
Issue-ID: DCAEGEN2-198 Change-Id: I09296ae4d13a0ad442bc139e69c13d19e4be0916 Signed-off-by: Vijay <vv770d@att.com>
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/org/onap/dcae/commonFunction/EventPublisher.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/org/onap/dcae/commonFunction/EventPublisher.java b/src/main/java/org/onap/dcae/commonFunction/EventPublisher.java
index 0d9cf91e..d76299df 100644
--- a/src/main/java/org/onap/dcae/commonFunction/EventPublisher.java
+++ b/src/main/java/org/onap/dcae/commonFunction/EventPublisher.java
@@ -148,7 +148,7 @@ public class EventPublisher {
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));
@@ -156,6 +156,9 @@ public class EventPublisher {
} catch (IOException | GeneralSecurityException | IllegalArgumentException e) {
log.error("Unable to publish event: {} streamid: {}. Exception: {}", event, streamid, e);
}
+ finally {
+ closePublisher();
+ }
}