File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed
src/main/java/com/arpnetworking/clusteraggregator Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -111,14 +111,14 @@ public void onReceive(final Object message) throws Exception {
111
111
final ClusterEvent .CurrentClusterState clusterState = (ClusterEvent .CurrentClusterState ) message ;
112
112
_clusterState = Optional .of (clusterState );
113
113
114
- final Metrics metrics = _metricsFactory .create ();
115
- metrics .setGauge ("akka/members_count" , clusterState .members ().size ());
116
- if (_cluster .selfAddress ().equals (clusterState .getLeader ())) {
117
- metrics .setGauge ("akka/is_leader" , 1 );
118
- } else {
119
- metrics .setGauge ("akka/is_leader" , 0 );
114
+ try (final Metrics metrics = _metricsFactory .create ()) {
115
+ metrics .setGauge ("akka/members_count" , clusterState .members ().size ());
116
+ if (_cluster .selfAddress ().equals (clusterState .getLeader ())) {
117
+ metrics .setGauge ("akka/is_leader" , 1 );
118
+ } else {
119
+ metrics .setGauge ("akka/is_leader" , 0 );
120
+ }
120
121
}
121
- metrics .close ();
122
122
} else if (message instanceof GetRequest ) {
123
123
sendResponse (getSender ());
124
124
} else if (message instanceof ParallelLeastShardAllocationStrategy .RebalanceNotification ) {
You can’t perform that action at this time.
0 commit comments