Write Listener (Rev 4)

Author: scottf

src/main/java/io/nats/client/impl/NatsConnectionWriter.java

@@ -178,7 +178,7 @@ void sendMessageBatch(NatsMessage msg, DataPort dataPort, StatisticsCollector st
                 stats.incrementOut(size);
                 if (writeListener != null) {
                     NatsMessage finalMsg = msg;
-                    writeListener.submit(() -> writeListener.buffered(finalMsg, mode.get()));
+                    writeListener.submit(() -> writeListener.buffered(finalMsg, mode.get().name()));
                 }
 
                 if (msg.flushImmediatelyAfterPublish) {

src/main/java/io/nats/client/impl/WriteListener.java

@@ -13,6 +13,7 @@
 
 package io.nats.client.impl;
 
+import io.nats.client.Message;
 import org.jspecify.annotations.Nullable;
 
 import java.util.concurrent.ExecutorService;
@@ -35,5 +36,5 @@ public final void submit(Runnable runnable) {
         executorService.submit(runnable);
     }
 
-    public abstract void buffered(NatsMessage msg, NatsConnectionWriter.Mode mode);
+    public abstract void buffered(Message msg, String mode);
 }