public Set getLatestTargetRunnerConfig()

in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java [59:76]

• 18 lines of code
• 6 McCabe index (conditional complexity)

    public Set<TargetRunnerConfig> getLatestTargetRunnerConfig() {
        List<EventTargetRunner> eventTargetRunners = null;
        try {
            eventTargetRunners = eventTargetRunnerRepository.listEventTargetRunners(null, null, null);
        } catch (Throwable e) {
            if (e.getMessage().contains("not found")) {
                return Sets.newHashSet();
            }
        }
        if (eventTargetRunners == null || eventTargetRunners.isEmpty()) {
            return Sets.newHashSet();
        }
        Set<TargetRunnerConfig> targetRunnerConfigs = Sets.newHashSet();
        for (EventTargetRunner eventTargetRunner : eventTargetRunners) {
            targetRunnerConfigs.add(new Gson().fromJson(eventTargetRunner.getRunContext(), TargetRunnerConfig.class));
        }
        return targetRunnerConfigs;
    }