@Override
    public Source openSource(final long streamId, final boolean anyStatus) throws DataException {
        try {
            LOGGER.debug(() -> "openSource() " + streamId);

            final Meta meta = metaService.getMeta(streamId, anyStatus);
            if (meta == null) {
                if (anyStatus) {
                    throw new DataException("Unable to find meta data for id=" + streamId + " with any status");
                } else {
                    throw new DataException("Unable to find meta data for id=" + streamId + " with valid status");
                }
            }

            final DataVolume dataVolume = dataVolumeService.findDataVolume(meta.getId());
            if (dataVolume == null) {
                throw new DataException("Unable to find any volume for " + meta);
            }

            Source source = null;
            switch (dataVolume.getVolume().getVolumeType()) {
                case STANDARD -> {
                    final Path volumePath = pathCreator.toAppPath(dataVolume.getVolume().getPath());
                    source = FsSource.create(fileSystemStreamPathHelper, meta, volumePath, meta.getTypeName());
                }
                case S3 -> source = s3Store.getSource(dataVolume, meta);
            }

            return source;
        } catch (final DataException e) {
            LOGGER.debug(e::getMessage, e);
            throw e;
        }
    }
<p>
Open a existing stream source.
</p>

@param streamId  The stream id to open a stream source for.
@param anyStatus Used to specify if this method will return stream sources that
                 are logically deleted or locked. If false only unlocked stream
                 sources will be returned, null otherwise.
@return The loaded stream source if it exists (has not been physically
deleted) else null. Also returns null if one exists but is
logically deleted or locked unless <code>anyStatus</code> is
true.
@throws DataException Could be thrown if no volume
stroom-data/stroom-data-store-impl-fs/src/main/java/stroom/data/store/impl/fs/FsStore.java