call removeCloseListener

Author: JerryShea

src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueue.java

@@ -932,9 +932,14 @@ private ToIntFunction<String> fileNameToCycleFunction() {
         return name -> dateCache.parseCount(name.substring(0, name.length() - SUFFIX.length()));
     }
 
+    @Deprecated(/* to be removed in x.25 */)
     void removeCloseListener(final StoreTailer storeTailer) {
+        removeCloseListener((java.io.Closeable) storeTailer);
+    }
+
+    void removeCloseListener(final java.io.Closeable closeable) {
         synchronized (closers) {
-            closers.removeIf(wrc -> wrc.get() == storeTailer);
+            closers.removeIf(wrc -> wrc.get() == closeable);
         }
     }
 

src/main/java/net/openhft/chronicle/queue/impl/single/StoreAppender.java

@@ -209,6 +209,8 @@ public void writeBytes(@NotNull final WriteBytesMarshallable marshallable) {
 
     @Override
     protected void performClose() {
+        queue.removeCloseListener(this);
+
         releaseBytesFor(wireForIndex);
         releaseBytesFor(wire);
         releaseBytesFor(bufferWire);

src/main/java/net/openhft/chronicle/queue/impl/single/StoreTailer.java

@@ -156,6 +156,7 @@ public DocumentContext readingDocument() {
 
     @Override
     protected void performClose() {
+        queue.removeCloseListener((java.io.Closeable) this);
         Closeable.closeQuietly(indexValue);
         // the wire ref count will be released here by setting it to null
         context.wire(null);