public void event()

in elasticjob-cloud/elasticjob-cloud-scheduler/src/main/java/org/apache/shardingsphere/elasticjob/cloud/scheduler/state/disable/job/CloudJobDisableListener.java [44:57]

• 14 lines of code
• 8 McCabe index (conditional complexity)

    public void event(final Type type, final ChildData oldData, final ChildData data) {
        String path = Type.NODE_DELETED == type ? oldData.getPath() : data.getPath();
        if (Type.NODE_CREATED == type && isJobDisableNode(path)) {
            String jobName = path.substring(DisableJobNode.ROOT.length() + 1);
            if (Objects.nonNull(jobName)) {
                producerManager.unschedule(jobName);
            }
        } else if (Type.NODE_DELETED == type && isJobDisableNode(path)) {
            String jobName = path.substring(DisableJobNode.ROOT.length() + 1);
            if (Objects.nonNull(jobName)) {
                producerManager.reschedule(jobName);
            }
        }
    }