Remove commented out calls to throwExceptionIfClosed. Fixes #1386 (#1387

)
OpenHFT · Jul 13, 2023 · 5077374 · 5077374
1 parent 108557b
commit 5077374
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueue.java b/src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueue.java
@@ -270,15 +270,11 @@ public int sourceId() {
      */
     @Override
     public long lastAcknowledgedIndexReplicated() {
-        // throwExceptionIfClosed();
-
         return lastAcknowledgedIndexReplicated == null ? -1 : lastAcknowledgedIndexReplicated.getVolatileValue(-1);
     }
 
     @Override
     public void lastAcknowledgedIndexReplicated(long newValue) {
-        // throwExceptionIfClosed();
-
         if (lastAcknowledgedIndexReplicated != null)
             lastAcknowledgedIndexReplicated.setMaxValue(newValue);
     }

diff --git a/src/main/java/net/openhft/chronicle/queue/impl/single/StoreTailer.java b/src/main/java/net/openhft/chronicle/queue/impl/single/StoreTailer.java
@@ -146,8 +146,6 @@ public boolean readDocument(@NotNull final ReadMarshallable reader) {
     @Override
     @NotNull
     public DocumentContext readingDocument() {
-//        throwExceptionIfClosed();
-
         // trying to create an initial document without a direction should not consume a message
         final long index = index();
         if (direction == NONE && (index == indexAtCreation || index == 0) && !readingDocumentFound) {