diff --git a/server/core/src/main/java/org/infinispan/server/core/transport/NettyTransportConnectionStats.java b/server/core/src/main/java/org/infinispan/server/core/transport/NettyTransportConnectionStats.java index d434d43f1a08..15b27c45678c 100644 --- a/server/core/src/main/java/org/infinispan/server/core/transport/NettyTransportConnectionStats.java +++ b/server/core/src/main/java/org/infinispan/server/core/transport/NettyTransportConnectionStats.java @@ -89,7 +89,15 @@ static class ConnectionAdderTask implements Function protocolServer = SecurityActions.getGlobalComponentRegistry(embeddedCacheManager) + .getComponent(ProtocolServer.class, serverName); + // protocol server not registered; so no connections are open. + if (protocolServer == null) { + return 0; + } + Transport transport = protocolServer.getTransport(); + // check if the transport is up; otherwise no connections are open + return transport == null ? 0 : transport.getNumberOfLocalConnections(); } public static class Externalizer implements org.infinispan.commons.marshall.Externalizer {