We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 724e7bf commit a144ccfCopy full SHA for a144ccf
src/main/java/com/arpnetworking/clusteraggregator/ClusterStatusCache.java
@@ -149,10 +149,12 @@ public Receive createReceive() {
149
}
150
for (final Map.Entry<String, Integer> entry : shardsPerAddress.entrySet()) {
151
try (Metrics metrics = _metricsFactory.create()) {
152
- final Long actorCount = actorsPerAddress.get(entry.getKey());
153
metrics.addAnnotation("address", entry.getKey());
154
metrics.setGauge("akka/cluster/shards", entry.getValue());
155
- metrics.setGauge("akka/cluster/actors", actorCount);
+ @Nullable final Long actorCount = actorsPerAddress.get(entry.getKey());
+ if (actorCount != null) {
156
+ metrics.setGauge("akka/cluster/actors", actorCount);
157
+ }
158
159
160
})
0 commit comments