From 2ff90ca8503aeba438c374f9cc1255de1f749418 Mon Sep 17 00:00:00 2001 From: Wojciech Lukowicz Date: Fri, 18 Oct 2024 16:42:21 +0100 Subject: [PATCH] make FIX_MESSAGE also apply to messages sent using SessionWriter --- .../java/uk/co/real_logic/artio/session/SessionWriter.java | 4 ++++ 1 file changed, 4 insertions(+) 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 e7782d6617..d1752b9508 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 @@ -17,6 +17,7 @@ import org.agrona.DirectBuffer; import uk.co.real_logic.artio.CommonConfiguration; +import uk.co.real_logic.artio.DebugLogger; import uk.co.real_logic.artio.builder.Encoder; import uk.co.real_logic.artio.dictionary.SessionConstants; import uk.co.real_logic.artio.messages.DisconnectReason; @@ -24,6 +25,7 @@ import uk.co.real_logic.artio.util.MutableAsciiBuffer; import static uk.co.real_logic.artio.GatewayProcess.NO_CONNECTION_ID; +import static uk.co.real_logic.artio.LogTag.FIX_MESSAGE; import static uk.co.real_logic.artio.messages.MessageStatus.OK; /** @@ -158,6 +160,8 @@ public long send( if (position > 0) { + DebugLogger.logFixMessage(FIX_MESSAGE, messageType, "Sent ", messageBuffer, offset, length); + final InternalSession session = this.session; if (session != null) {