diff --git a/artio-core/src/main/java/uk/co/real_logic/artio/library/SessionHandler.java b/artio-core/src/main/java/uk/co/real_logic/artio/library/SessionHandler.java index 514220873c..2fa88ef973 100644 --- a/artio-core/src/main/java/uk/co/real_logic/artio/library/SessionHandler.java +++ b/artio-core/src/main/java/uk/co/real_logic/artio/library/SessionHandler.java @@ -35,7 +35,7 @@ public interface SessionHandler * @param libraryId the id of library which has received this message. * @param session the session which has received this message. * @param sequenceIndex the sequence index of this message. - * @param messageType the FIX msgType field, encoded as an int. + * @param messageType the FIX msgType field, encoded as a long. * @param timestampInNs the time of the message in nanoseconds. * @param position the position in the Aeron stream at the end of the message. * @param messageInfo additional information about the message. @@ -56,7 +56,8 @@ Action onMessage( /** * This session has timed out on this library. It is still connected, but will * be managed by the gateway. - * @param libraryId the id of library which the session used to owned by. + * + * @param libraryId the id of library which the session used to owned by. * @param session the session that has timed out. */ void onTimeout(int libraryId, Session session); @@ -67,7 +68,7 @@ Action onMessage( * the wiki * for details on what a slow consumer is. * - * @param libraryId the id of library which the session used to owned by. + * @param libraryId the id of library which the session used to owned by. * @param session the session that has become slow. * @param hasBecomeSlow true iff the session has been detected as slow, false if it is no longer slow. */ @@ -84,7 +85,7 @@ Action onMessage( Action onDisconnect(int libraryId, Session session, DisconnectReason reason); /** - * Invoked When a client resets a session to the initial sequence number via a logon whilst still connected. + * Invoked when a client resets a session to the initial sequence number via a logon whilst still connected. * * @param session The session that has just started. */ diff --git a/artio-core/src/main/java/uk/co/real_logic/artio/session/SessionWriter.java b/artio-core/src/main/java/uk/co/real_logic/artio/session/SessionWriter.java index 7ee87c822a..3fc76c7e3d 100644 --- a/artio-core/src/main/java/uk/co/real_logic/artio/session/SessionWriter.java +++ b/artio-core/src/main/java/uk/co/real_logic/artio/session/SessionWriter.java @@ -82,7 +82,7 @@ public void sequenceIndex(final int sequenceIndex) } /** - * Sets the current sequence index. + * Gets the current sequence index. * * @return the current sequence index */ diff --git a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java index c360496559..85a3151940 100644 --- a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java +++ b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SlowConsumerTest.java @@ -368,4 +368,3 @@ private void setup(final int senderMaxBytesInBuffer, final MessageTimingCaptor m library = testSystem.connect(libraryConfiguration); } } -