public void publish()

in data-index/kogito-addons-quarkus-data-index-persistence/kogito-addons-quarkus-data-index-persistence-common/runtime/src/main/java/org/kie/kogito/index/addon/DataIndexEventPublisher.java [52:85]

34 lines of code
16 McCabe index (conditional complexity)


    public void publish(DataEvent<?> event) {
        LOGGER.debug("Sending event to embedded data index: {}", event);
        switch (event.getType()) {
            case PROCESS_DEFINITION_EVENT:
                indexingService.indexProcessDefinition((ProcessDefinitionDataEvent) event);
                break;
            case "ProcessInstanceErrorDataEvent":
            case "ProcessInstanceNodeDataEvent":
            case "ProcessInstanceSLADataEvent":
            case "ProcessInstanceStateDataEvent":
            case "ProcessInstanceVariableDataEvent":
                indexingService.indexProcessInstanceEvent((ProcessInstanceDataEvent<?>) event);
                break;
            case "UserTaskInstanceAssignmentDataEvent":
            case "UserTaskInstanceAttachmentDataEvent":
            case "UserTaskInstanceCommentDataEvent":
            case "UserTaskInstanceDeadlineDataEvent":
            case "UserTaskInstanceStateDataEvent":
            case "UserTaskInstanceVariableDataEvent":
                indexingService.indexUserTaskInstanceEvent((UserTaskInstanceDataEvent<?>) event);
                break;
            case "JobEvent":
                try {
                    Job job = getObjectMapper().readValue(new String((byte[]) event.getData()), Job.class);
                    job.setEndpoint(event.getSource() == null ? null : event.getSource().toString());
                    indexingService.indexJob(job);
                } catch (IOException e) {
                    throw new UncheckedIOException(e);
                }
                break;
            default:
                LOGGER.debug("Unknown type of event '{}', ignoring for this publisher", event.getType());
        }
    }