[Java] Comments and cleanup.

real-logic · Aug 29, 2024 · 55e8be6 · 55e8be6
1 parent a7d866f
commit 55e8be6
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 4 deletions.
diff --git a/aeron-client/src/main/java/io/aeron/Aeron.java b/aeron-client/src/main/java/io/aeron/Aeron.java
@@ -1736,6 +1736,7 @@ public ThreadFactory threadFactory()
          *
          * @param publicationErrorFrameHandler to be called back when an error frame is received.
          * @return this for a fluent API.
+         * @since 1.47.0
          */
         public Context publicationErrorFrameHandler(
             final PublicationErrorFrameHandler publicationErrorFrameHandler)
@@ -1749,6 +1750,7 @@ public Context publicationErrorFrameHandler(
          * this client.
          *
          * @return the {@link PublicationErrorFrameHandler} to call back on to.
+         * @since 1.47.0
          */
         public PublicationErrorFrameHandler publicationErrorFrameHandler()
         {

diff --git a/aeron-client/src/main/java/io/aeron/PublicationErrorFrameHandler.java b/aeron-client/src/main/java/io/aeron/PublicationErrorFrameHandler.java
@@ -19,6 +19,7 @@
 
 /**
  * Interface for handling various error frame messages for publications.
+ * @since 1.47.0
  */
 public interface PublicationErrorFrameHandler
 {

diff --git a/aeron-client/src/main/java/io/aeron/command/ControlProtocolEvents.java b/aeron-client/src/main/java/io/aeron/command/ControlProtocolEvents.java
@@ -171,6 +171,7 @@ public class ControlProtocolEvents
 
     /**
      * Inform clients of error frame received by publication
+     * @since 1.47.0
      */
     public static final int ON_PUBLICATION_ERROR = 0x0F0C;
 }
diff --git a/aeron-client/src/main/java/io/aeron/command/PublicationErrorFrameFlyweight.java b/aeron-client/src/main/java/io/aeron/command/PublicationErrorFrameFlyweight.java
@@ -62,6 +62,7 @@
  * ...                                                              |
  *  +---------------------------------------------------------------+
  * </pre>
+ * @since 1.47.0
  */
 public class PublicationErrorFrameFlyweight
 {

diff --git a/aeron-client/src/main/java/io/aeron/protocol/ErrorFlyweight.java b/aeron-client/src/main/java/io/aeron/protocol/ErrorFlyweight.java
@@ -50,6 +50,7 @@
  *    ...                                                             |
  *    +---------------------------------------------------------------+
  * </pre>
+ * @since 1.47.0
  */
 public class ErrorFlyweight extends HeaderFlyweight
 {

diff --git a/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java b/aeron-driver/src/main/java/io/aeron/driver/PublicationImage.java
@@ -592,10 +592,6 @@ int insertPacket(
 
         if (null != rejectionReason)
         {
-            if (isEndOfStream)
-            {
-                System.out.println("Invalidated end of stream");
-            }
             return 0;
         }
-Original file line number
+Diff line change
@@ Expand Up / @@ -19,6 +19,7 @@ @@
     /**
      * Interface for handling various error frame messages for publications.
+     * @since 1.47.0
      */
     public interface PublicationErrorFrameHandler
     {
@@ Expand Down @@