Close the metric.

Matthew Hayter · Matthew Hayter · commit fd1fe647de20 · 2016-05-20T13:29:57.000-07:00
diff --git a/src/main/java/com/arpnetworking/clusteraggregator/ClusterStatusCache.java b/src/main/java/com/arpnetworking/clusteraggregator/ClusterStatusCache.java
@@ -118,6 +118,7 @@ public void onReceive(final Object message) throws Exception {
                 } else {
                     metrics.setGauge("akka/is_leader", 0);
                 }
+                metrics.close();
             } else if (message instanceof GetRequest) {
                 sendResponse(getSender());
             } else if (message instanceof ParallelLeastShardAllocationStrategy.RebalanceNotification) {

Original file line number	Diff line number	Diff line change
`@@ -118,6 +118,7 @@ public void onReceive(final Object message) throws Exception {`
`118`	`118`	`} else {`
`119`	`119`	`metrics.setGauge("akka/is_leader", 0);`
`120`	`120`	`}`
	`121`	`+ metrics.close();`
`121`	`122`	`} else if (message instanceof GetRequest) {`
`122`	`123`	`sendResponse(getSender());`
`123`	`124`	`} else if (message instanceof ParallelLeastShardAllocationStrategy.RebalanceNotification) {`