public DXTickStream getStream()

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);
    }