Key Value Implementation

nats-io · Dec 10, 2024 · a717604 · a717604
1 parent ed10ce9
commit a717604
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/main/java/io/nats/vertx/impl/NatsKeyValueImpl.java b/src/main/java/io/nats/vertx/impl/NatsKeyValueImpl.java
@@ -6,7 +6,6 @@
 import io.nats.client.impl.NatsKeyValueWatchSubscription;
 import io.nats.client.impl.NatsMessage;
 import io.nats.client.support.DateTimeUtils;
-import io.nats.client.support.Debug;
 import io.nats.client.support.Validator;
 import io.nats.vertx.NatsKeyValue;
 import io.vertx.core.Future;
@@ -34,7 +33,7 @@ public class NatsKeyValueImpl extends NatsImpl implements NatsKeyValue {
 
     // JNats KeyValue parallel variables
     private final String bucketName;
-    private String streamName;
+    private final String streamName;
     private final String streamSubject;
     private final String readPrefix;
     private final String writePrefix;
@@ -146,7 +145,6 @@ public Future<Long> create(String key, byte[] value) {
                     promise.fail(e);
                 }
             } catch (Exception e) {
-                Debug.info("CR EX", e);
                 handleException(promise, e);
             }
         }, false);