in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseStreamReplicationServiceTest.java [139:168]
private List<BaseTestClass> getTimeBaseEntities() {
List<BaseTestClass> entities = new ArrayList<>();
FirstTestClass firstMessage = new FirstTestClass();
firstMessage.setCharValue('c');
firstMessage.setIntValue(27);
firstMessage.setLongValue(2l);
firstMessage.setByteaValue(new ByteArrayList("Some bytes".getBytes()));
firstMessage.setStringValue("some string");
firstMessage.setDecimal64Value(Decimal64.fromDouble(123456.789564321d));
firstMessage.setSymbol("firstsymbol");
firstMessage.setInnerState(new InnerTestClass("Name", "Value"));
firstMessage.setTimeStampMs(TimeStampedMessage.TIMESTAMP_UNKNOWN);
entities.add(firstMessage);
SecondTestClass secondMessage = new SecondTestClass();
secondMessage.setEnumValue(SomeTestEnum.ONE);
secondMessage.setSecondLongValue(4l);
secondMessage.setSecondValue1("second string value");
secondMessage.setByteaValue(new ByteArrayList("second value bytes".getBytes()));
secondMessage.setDecimal64Value(Decimal64.fromDouble(78.123654789d));
secondMessage.setStringValue("string value 2");
secondMessage.setSymbol("secondsymbol");
secondMessage.setTimeStampMs(TimeStampedMessage.TIMESTAMP_UNKNOWN);
entities.add(secondMessage);
return entities;
}