Skip to content

Commit 259ec6d

Browse files
committed
use onWarnEvent() in Session where applicable
1 parent d94796e commit 259ec6d

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

quickfixj-core/src/main/java/quickfix/Session.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1060,31 +1060,31 @@ private void next(Message message, boolean isProcessingQueuedMessages) throws Fi
10601060
if (rejectInvalidMessage) {
10611061
throw e;
10621062
} else {
1063-
getLog().onErrorEvent("Warn: incoming message with " + e + ": " + getMessageToLog(message));
1063+
getLog().onWarnEvent("incoming message with " + e + ": " + getMessageToLog(message));
10641064
}
10651065
} catch (final FieldException e) {
10661066
if (message.isSetField(e.getField())) {
10671067
if (rejectInvalidMessage) {
10681068
throw e;
10691069
} else {
1070-
getLog().onErrorEvent(
1071-
"Warn: incoming message with incorrect field: "
1070+
getLog().onWarnEvent(
1071+
"incoming message with incorrect field: "
10721072
+ message.getField(e.getField()) + ": " + getMessageToLog(message));
10731073
}
10741074
} else {
10751075
if (rejectInvalidMessage) {
10761076
throw e;
10771077
} else {
1078-
getLog().onErrorEvent(
1079-
"Warn: incoming message with missing field: " + e.getField()
1078+
getLog().onWarnEvent(
1079+
"incoming message with missing field: " + e.getField()
10801080
+ ": " + e.getMessage() + ": " + getMessageToLog(message));
10811081
}
10821082
}
10831083
} catch (final FieldNotFound e) {
10841084
if (rejectInvalidMessage) {
10851085
throw e;
10861086
} else {
1087-
getLog().onErrorEvent("Warn: incoming " + e + ": " + getMessageToLog(message));
1087+
getLog().onWarnEvent("incoming " + e + ": " + getMessageToLog(message));
10881088
}
10891089
}
10901090
}

0 commit comments

Comments
 (0)