self-review 3

scottf · scottf · commit 0b7dfd9a07da · 2025-09-24T17:38:14.000-04:00
diff --git a/src/main/java/io/nats/client/impl/NatsConsumerContext.java b/src/main/java/io/nats/client/impl/NatsConsumerContext.java
@@ -153,6 +153,7 @@ private void checkNotPinned(String label) throws IOException {
             }
         }
     }
+
     private NatsMessageConsumerBase trackConsume(NatsMessageConsumerBase con) {
         lastConsumer.set(con);
         return con;
@@ -221,6 +222,7 @@ public Message next(long maxWaitMillis) throws IOException, InterruptedException
         try {
             stateLock.lock();
             checkState();
+            checkNotPinned("Next");
 
             try {
                 long inactiveThreshold = maxWaitMillis * 110 / 100; // 10% longer than the wait

Original file line number	Diff line number	Diff line change
`@@ -153,6 +153,7 @@ private void checkNotPinned(String label) throws IOException {`
`153`	`153`	`}`
`154`	`154`	`}`
`155`	`155`	`}`
	`156`	`+`
`156`	`157`	`private NatsMessageConsumerBase trackConsume(NatsMessageConsumerBase con) {`
`157`	`158`	`lastConsumer.set(con);`
`158`	`159`	`return con;`
`@@ -221,6 +222,7 @@ public Message next(long maxWaitMillis) throws IOException, InterruptedException`
`221`	`222`	`try {`
`222`	`223`	`stateLock.lock();`
`223`	`224`	`checkState();`
	`225`	`+ checkNotPinned("Next");`
`224`	`226`
`225`	`227`	`try {`
`226`	`228`	`long inactiveThreshold = maxWaitMillis * 110 / 100; // 10% longer than the wait`