diff --git a/repository/src/main/java/org/alfresco/repo/event2/EventConsolidator.java b/repository/src/main/java/org/alfresco/repo/event2/EventConsolidator.java index faa4a05214..33c3dcaf7e 100644 --- a/repository/src/main/java/org/alfresco/repo/event2/EventConsolidator.java +++ b/repository/src/main/java/org/alfresco/repo/event2/EventConsolidator.java @@ -2,7 +2,7 @@ * #%L * Alfresco Repository * %% - * Copyright (C) 2005 - 2023 Alfresco Software Limited + * Copyright (C) 2005 - 2025 Alfresco Software Limited * %% * This file is part of the Alfresco software. * If the software was purchased under a paid Alfresco license, the terms of @@ -94,19 +94,26 @@ public abstract class EventConsolidator> getRepoEvent(EventInfo eventInfo) + { + final RepoEvent.Builder> builder = RepoEvent.builder(); + + configureRepoEventBuilder(builder, eventInfo); + + return builder.build(); + } + + protected void configureRepoEventBuilder(RepoEvent.Builder> builder, EventInfo eventInfo) { EventType eventType = getDerivedEvent(); DataAttributes eventData = buildEventData(eventInfo, resource, eventType); - return RepoEvent.>builder() - .setId(eventInfo.getId()) - .setSource(eventInfo.getSource()) - .setTime(eventInfo.getTimestamp()) - .setType(eventType.getType()) - .setData(eventData) - .setDataschema(EventJSONSchema.getSchemaV1(eventType)) - .build(); + builder.setId(eventInfo.getId()) + .setSource(eventInfo.getSource()) + .setTime(eventInfo.getTimestamp()) + .setType(eventType.getType()) + .setData(eventData) + .setDataschema(EventJSONSchema.getSchemaV1(eventType)); } /**