Madan Jampani

Shutting down AE executor on GossipLinkStore deactivate

...@@ -152,6 +152,16 @@ public class GossipLinkStore ...@@ -152,6 +152,16 @@ public class GossipLinkStore
152 152
153 @Deactivate 153 @Deactivate
154 public void deactivate() { 154 public void deactivate() {
155 +
156 + executor.shutdownNow();
157 + try {
158 + if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
159 + log.error("Timeout during executor shutdown");
160 + }
161 + } catch (InterruptedException e) {
162 + log.error("Error during executor shutdown", e);
163 + }
164 +
155 linkDescs.clear(); 165 linkDescs.clear();
156 links.clear(); 166 links.clear();
157 srcLinks.clear(); 167 srcLinks.clear();
......