in data-index/data-index-service/data-index-service-common/src/main/java/org/kie/kogito/index/service/messaging/KogitoIndexEventConverter.java [200:219]
private DataEvent<?> buildUserTaskInstanceDataEvent(CloudEvent cloudEvent) throws IOException {
switch (cloudEvent.getType()) {
case MultipleUserTaskInstanceDataEvent.TYPE:
return DataEventFactory.from(new MultipleUserTaskInstanceDataEvent(), cloudEvent, taskCollectionConverter);
case "UserTaskInstanceAssignmentDataEvent":
return DataEventFactory.from(new UserTaskInstanceAssignmentDataEvent(), cloudEvent, assignConverter);
case "UserTaskInstanceAttachmentDataEvent":
return DataEventFactory.from(new UserTaskInstanceAttachmentDataEvent(), cloudEvent, attachConverter);
case "UserTaskInstanceCommentDataEvent":
return DataEventFactory.from(new UserTaskInstanceCommentDataEvent(), cloudEvent, commentConverter);
case "UserTaskInstanceDeadlineDataEvent":
return DataEventFactory.from(new UserTaskInstanceDeadlineDataEvent(), cloudEvent, deadlineConverter);
case "UserTaskInstanceStateDataEvent":
return DataEventFactory.from(new UserTaskInstanceStateDataEvent(), cloudEvent, taskStateConverter);
case "UserTaskInstanceVariableDataEvent":
return DataEventFactory.from(new UserTaskInstanceVariableDataEvent(), cloudEvent, taskVariableConverter);
default:
throw new IllegalArgumentException("Unknown UserTaskInstanceDataEvent variant: " + cloudEvent.getType());
}
}