in java/runner/src/intTest/java/com/epam/deltix/data/connectors/validator/L2DataValidator.java [312:337]
private void validateTradeFields(PackageHeaderInfo headerInfo, TradeEntry entry) {
MarketSide<OrderBookQuote> quotes = book.getMarketSide(QuoteSide.ASK);
if (quotes == null || quotes.depth() == 0) {
quotes = book.getMarketSide(QuoteSide.BID);
}
if (Decimal64Utils.isNull(entry.getPrice()) || Decimal64Utils.isZero(entry.getPrice())) {
sendMessageToLogger(headerInfo, quotes.getQuote(0).getExchangeId(),
"Trade price is null or zero", Severity.ERROR
);
}
if (Decimal64Utils.isNull(entry.getSize()) || Decimal64Utils.isZero(entry.getSize())) {
sendMessageToLogger(headerInfo, quotes.getQuote(0).getExchangeId(),
"Trade size is null or zero", Severity.ERROR
);
}
if (!SKIP_CONNECTORS_TRADE_SIDE_VALIDATION.contains(stream.toString())) {
if (entry.getSide() == null) {
sendMessageToLogger(headerInfo, quotes.getQuote(0).getExchangeId(),
"Trade side doesn't exist", Severity.WARNING
);
}
}
}