in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseConnectionService.java [40:55]
public DXTickStream getStream(String streamName) {
lock.lock();
try {
if (!isOpen.get()) {
init(Boolean.TRUE);
}
} catch (Exception ex) {
LOG.error().append("Could not open timebase connection").append(ex).commit();
isOpen.set(Boolean.FALSE);
} finally {
lock.unlock();
}
LOG.debug().append("Try to open stream: ").append(streamName).commit();
return timebase.getStream(streamName);
}