Skip to content

Commit

Permalink
Logs to investigate
Browse files Browse the repository at this point in the history
  • Loading branch information
Denis Plotnikov committed Oct 8, 2023
1 parent f7f122f commit 959ae26
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions src/main/java/com/exactpro/th2/FixHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -732,6 +732,8 @@ private boolean checkLogon(ByteBuf message) {

@Override
public void onOutgoing(@NotNull IChannel channel, @NotNull ByteBuf message, @NotNull Map<String, String> metadata) {
if (LOGGER.isInfoEnabled()) LOGGER.info("Outgoing message before update: ${}", message.toString(US_ASCII));

strategy.getOutgoingMessageStrategy(OutgoingMessagesStrategy::getOutgoingMessageProcessor).process(message, metadata);

if (LOGGER.isInfoEnabled()) LOGGER.info("Outgoing message: {}", message.toString(US_ASCII));
Expand Down Expand Up @@ -823,9 +825,12 @@ public void onOutgoingUpdateTag(@NotNull ByteBuf message, @NotNull Map<String, S
FixField sendingTime = findField(message, SENDING_TIME_TAG, US_ASCII, bodyLength);

if (sendingTime == null) {
LOGGER.info("Sending time tag value 1: {}", new String(targetCompID.getBytes()));
targetCompID.insertNext(SENDING_TIME_TAG, getTime());
} else {
LOGGER.info("Sending time tag value 2: {}", new String(sendingTime.getBytes()));
sendingTime.setValue(getTime());
LOGGER.info("Sending time tag value 3: {}", new String(sendingTime.getBytes()));
}

updateLength(message);
Expand Down

0 comments on commit 959ae26

Please sign in to comment.