diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index 3566ac094..070611d1a 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -75,7 +75,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon private final ReaderWithSize valueReaderWithSize; @NotNull private final WriterWithSize valueWriterWithSize; - private volatile SocketChannel clientChannel; + private SocketChannel clientChannel; @Nullable private CloseablesManager closeables; @@ -309,11 +309,12 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon throw new UnsupportedOperationException(); } - public void close() { + public synchronized void close() { if (closeables != null) closeables.closeQuietly(); closeables = null; + clientChannel = null; }