From 063432415109b2b2ff86c457e6d040efeb03f36b Mon Sep 17 00:00:00 2001 From: Thomas Georgios Giannos Date: Wed, 21 Feb 2024 17:45:48 +0200 Subject: [PATCH] Adding dmp and description touched integration events --- .../outbox/OutboxIntegrationEvent.java | 4 + .../outbox/OutboxProperties.java | 18 ++- .../outbox/OutboxRepositoryImpl.java | 8 ++ .../DescriptionTouchedIntegrationEvent.java | 102 +++++++++++++++ ...riptionTouchedIntegrationEventHandler.java | 23 ++++ ...ionTouchedIntegrationEventHandlerImpl.java | 34 +++++ .../DmpTouchedIntegrationEvent.java | 116 ++++++++++++++++++ .../DmpTouchedIntegrationEventHandler.java | 24 ++++ ...DmpTouchedIntegrationEventHandlerImpl.java | 35 ++++++ .../description/DescriptionServiceImpl.java | 31 +++-- .../eu/eudat/service/dmp/DmpServiceImpl.java | 8 +- .../web/src/main/resources/config/queue.yml | 2 + 12 files changed, 389 insertions(+), 16 deletions(-) create mode 100644 dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEvent.java create mode 100644 dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandler.java create mode 100644 dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandlerImpl.java create mode 100644 dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEvent.java create mode 100644 dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandler.java create mode 100644 dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandlerImpl.java diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxIntegrationEvent.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxIntegrationEvent.java index 97d7c1c52..54d725201 100644 --- a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxIntegrationEvent.java +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxIntegrationEvent.java @@ -23,6 +23,10 @@ public class OutboxIntegrationEvent extends IntegrationEvent { public static final String USER_REMOVE = "USER_REMOVE"; + public static final String DMP_TOUCH = "DMP_TOUCH"; + + public static final String DESCRIPTION_TOUCH = "DESCRIPTION_TOUCH"; + public static final String WHAT_YOU_KNOW_ABOUT_ME_COMPLETED = "WHAT_YOU_KNOW_ABOUT_ME_COMPLETED"; public static final String GENERATE_FILE = "GENERATE_FILE"; diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxProperties.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxProperties.java index 431027f04..8a66f6a26 100644 --- a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxProperties.java +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxProperties.java @@ -19,6 +19,10 @@ public class OutboxProperties { private final String userTouchTopic; + private final String dmpTouchTopic; + + private final String descriptionTouchTopic; + private final String notifyTopic; private final String forgetMeCompletedTopic; @@ -32,8 +36,8 @@ public class OutboxProperties { String tenantRemovalTopic, String tenantReactivationTopic, String tenantUserInviteTopic, - String userRemovalTopic, - String userTouchTopic, + String userRemovalTopic, + String userTouchTopic, String dmpTouchTopic, String descriptionTouchTopic, String notifyTopic, String forgetMeCompletedTopic, String whatYouKnowAboutMeCompletedTopic, @@ -46,6 +50,8 @@ public class OutboxProperties { this.tenantUserInviteTopic = tenantUserInviteTopic; this.userRemovalTopic = userRemovalTopic; this.userTouchTopic = userTouchTopic; + this.dmpTouchTopic = dmpTouchTopic; + this.descriptionTouchTopic = descriptionTouchTopic; this.notifyTopic = notifyTopic; this.forgetMeCompletedTopic = forgetMeCompletedTopic; this.whatYouKnowAboutMeCompletedTopic = whatYouKnowAboutMeCompletedTopic; @@ -80,6 +86,14 @@ public class OutboxProperties { return userTouchTopic; } + public String getDmpTouchTopic() { + return dmpTouchTopic; + } + + public String getDescriptionTouchTopic() { + return descriptionTouchTopic; + } + public String getNotifyTopic() { return notifyTopic; } diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxRepositoryImpl.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxRepositoryImpl.java index 2e1529411..4ef2cd90b 100644 --- a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxRepositoryImpl.java +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/OutboxRepositoryImpl.java @@ -407,6 +407,14 @@ public class OutboxRepositoryImpl implements OutboxRepository { routingKey = this.outboxProperties.getUserTouchTopic(); break; } + case OutboxIntegrationEvent.DMP_TOUCH: { + routingKey = this.outboxProperties.getDmpTouchTopic(); + break; + } + case OutboxIntegrationEvent.DESCRIPTION_TOUCH: { + routingKey = this.outboxProperties.getDescriptionTouchTopic(); + break; + } case OutboxIntegrationEvent.FORGET_ME_COMPLETED: { routingKey = this.outboxProperties.getForgetMeCompletedTopic(); break; diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEvent.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEvent.java new file mode 100644 index 000000000..469fd7f5e --- /dev/null +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEvent.java @@ -0,0 +1,102 @@ +package eu.eudat.integrationevent.outbox.descriptiontouched; + +import eu.eudat.commons.enums.DescriptionStatus; +import eu.eudat.integrationevent.TrackedEvent; +import eu.eudat.model.persist.descriptionproperties.PropertyDefinitionPersist; + +import java.util.List; +import java.util.UUID; + +public class DescriptionTouchedIntegrationEvent extends TrackedEvent { + + private UUID id; + + private String label; + + private UUID dmpId; + + private UUID dmpDescriptionTemplateId; + + private UUID descriptionTemplateId; + + private DescriptionStatus status; + + private String description; + + private PropertyDefinitionPersist properties; + + private List tags; + + public UUID getId() { + return id; + } + + public void setId(UUID id) { + this.id = id; + } + + public String getLabel() { + return label; + } + + public void setLabel(String label) { + this.label = label; + } + + public UUID getDmpId() { + return dmpId; + } + + public void setDmpId(UUID dmpId) { + this.dmpId = dmpId; + } + + public UUID getDmpDescriptionTemplateId() { + return dmpDescriptionTemplateId; + } + + public void setDmpDescriptionTemplateId(UUID dmpDescriptionTemplateId) { + this.dmpDescriptionTemplateId = dmpDescriptionTemplateId; + } + + public UUID getDescriptionTemplateId() { + return descriptionTemplateId; + } + + public void setDescriptionTemplateId(UUID descriptionTemplateId) { + this.descriptionTemplateId = descriptionTemplateId; + } + + public DescriptionStatus getStatus() { + return status; + } + + public void setStatus(DescriptionStatus status) { + this.status = status; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + + public PropertyDefinitionPersist getProperties() { + return properties; + } + + public void setProperties(PropertyDefinitionPersist properties) { + this.properties = properties; + } + + public List getTags() { + return tags; + } + + public void setTags(List tags) { + this.tags = tags; + } + +} diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandler.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandler.java new file mode 100644 index 000000000..d2fb9fcdf --- /dev/null +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandler.java @@ -0,0 +1,23 @@ +package eu.eudat.integrationevent.outbox.descriptiontouched; + +import eu.eudat.model.persist.DescriptionPersist; + +public interface DescriptionTouchedIntegrationEventHandler { + + void handle(DescriptionTouchedIntegrationEvent event); + + static DescriptionTouchedIntegrationEvent buildEventFromPersistModel(DescriptionPersist persist) { + DescriptionTouchedIntegrationEvent event = new DescriptionTouchedIntegrationEvent(); + event.setId(persist.getId()); + event.setLabel(persist.getLabel()); + event.setDmpId(persist.getDmpId()); + event.setDmpDescriptionTemplateId(persist.getDmpDescriptionTemplateId()); + event.setDescriptionTemplateId(persist.getDescriptionTemplateId()); + event.setStatus(persist.getStatus()); + event.setDescription(persist.getDescription()); + event.setProperties(persist.getProperties()); + event.setTags(persist.getTags()); + return event; + } + +} diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandlerImpl.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandlerImpl.java new file mode 100644 index 000000000..34e206558 --- /dev/null +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/descriptiontouched/DescriptionTouchedIntegrationEventHandlerImpl.java @@ -0,0 +1,34 @@ +package eu.eudat.integrationevent.outbox.descriptiontouched; + +import eu.eudat.integrationevent.outbox.OutboxIntegrationEvent; +import eu.eudat.integrationevent.outbox.OutboxService; +import gr.cite.tools.logging.LoggerService; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.config.ConfigurableBeanFactory; +import org.springframework.context.annotation.Scope; +import org.springframework.stereotype.Component; + +import java.util.UUID; + +@Component +@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE) +public class DescriptionTouchedIntegrationEventHandlerImpl implements DescriptionTouchedIntegrationEventHandler { + + private static final LoggerService logger = new LoggerService(LoggerFactory.getLogger(DescriptionTouchedIntegrationEventHandlerImpl.class)); + + private final OutboxService outboxService; + + public DescriptionTouchedIntegrationEventHandlerImpl(OutboxService outboxService) { + this.outboxService = outboxService; + } + + @Override + public void handle(DescriptionTouchedIntegrationEvent event) { + OutboxIntegrationEvent message = new OutboxIntegrationEvent(); + message.setMessageId(UUID.randomUUID()); + message.setType(OutboxIntegrationEvent.DESCRIPTION_TOUCH); + message.setEvent(event); + this.outboxService.publish(message); + } + +} diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEvent.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEvent.java new file mode 100644 index 000000000..d33c07df6 --- /dev/null +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEvent.java @@ -0,0 +1,116 @@ +package eu.eudat.integrationevent.outbox.dmptouched; + +import eu.eudat.commons.enums.DmpAccessType; +import eu.eudat.commons.enums.DmpStatus; +import eu.eudat.integrationevent.TrackedEvent; +import eu.eudat.model.persist.DmpDescriptionTemplatePersist; +import eu.eudat.model.persist.dmpproperties.DmpBlueprintValuePersist; +import eu.eudat.model.persist.dmpproperties.DmpContactPersist; + +import java.util.List; +import java.util.Map; +import java.util.UUID; + +public class DmpTouchedIntegrationEvent extends TrackedEvent { + + private UUID id; + + private String label; + + private DmpStatus status; + + private List contacts; + + private Map dmpBlueprintValues; + + private String description; + + private String language; + + private UUID blueprint; + + private DmpAccessType accessType; + + private List descriptionTemplates; + + public UUID getId() { + return id; + } + + public void setId(UUID id) { + this.id = id; + } + + public String getLabel() { + return label; + } + + public void setLabel(String label) { + this.label = label; + } + + public DmpStatus getStatus() { + return status; + } + + public void setStatus(DmpStatus status) { + this.status = status; + } + + public List getContacts() { + return contacts; + } + + public void setContacts(List contacts) { + this.contacts = contacts; + } + + public Map getDmpBlueprintValues() { + return dmpBlueprintValues; + } + + public void setDmpBlueprintValues(Map dmpBlueprintValues) { + this.dmpBlueprintValues = dmpBlueprintValues; + } + + public String getDescription() { + return description; + } + + public void setDescription(String description) { + this.description = description; + } + + public String getLanguage() { + return language; + } + + public void setLanguage(String language) { + this.language = language; + } + + public UUID getBlueprint() { + return blueprint; + } + + public void setBlueprint(UUID blueprint) { + this.blueprint = blueprint; + } + + public DmpAccessType getAccessType() { + return accessType; + } + + public void setAccessType(DmpAccessType accessType) { + this.accessType = accessType; + } + + public List getDescriptionTemplates() { + return descriptionTemplates; + } + + public void setDescriptionTemplates(List descriptionTemplates) { + this.descriptionTemplates = descriptionTemplates; + } + +} diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandler.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandler.java new file mode 100644 index 000000000..4c70fb8f9 --- /dev/null +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandler.java @@ -0,0 +1,24 @@ +package eu.eudat.integrationevent.outbox.dmptouched; + +import eu.eudat.model.persist.DmpPersist; + +public interface DmpTouchedIntegrationEventHandler { + + void handle(DmpTouchedIntegrationEvent event); + + static DmpTouchedIntegrationEvent buildEventFromPersistModel(DmpPersist persist) { + DmpTouchedIntegrationEvent event = new DmpTouchedIntegrationEvent(); + event.setId(persist.getId()); + event.setLabel(persist.getLabel()); + event.setStatus(persist.getStatus()); + event.setContacts(persist.getProperties().getContacts()); + event.setDmpBlueprintValues(persist.getProperties().getDmpBlueprintValues()); + event.setDescription(persist.getDescription()); + event.setLanguage(persist.getLanguage()); + event.setBlueprint(persist.getBlueprint()); + event.setAccessType(persist.getAccessType()); + event.setDescriptionTemplates(persist.getDescriptionTemplates()); + return event; + } + +} diff --git a/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandlerImpl.java b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandlerImpl.java new file mode 100644 index 000000000..5d45a42e0 --- /dev/null +++ b/dmp-backend/core/src/main/java/eu/eudat/integrationevent/outbox/dmptouched/DmpTouchedIntegrationEventHandlerImpl.java @@ -0,0 +1,35 @@ +package eu.eudat.integrationevent.outbox.dmptouched; + +import eu.eudat.integrationevent.outbox.OutboxIntegrationEvent; +import eu.eudat.integrationevent.outbox.OutboxService; +import eu.eudat.integrationevent.outbox.tenantremoval.TenantRemovalIntegrationEventHandlerImpl; +import gr.cite.tools.logging.LoggerService; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.config.ConfigurableBeanFactory; +import org.springframework.context.annotation.Scope; +import org.springframework.stereotype.Component; + +import java.util.UUID; + +@Component +@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE) +public class DmpTouchedIntegrationEventHandlerImpl implements DmpTouchedIntegrationEventHandler { + + private static final LoggerService logger = new LoggerService(LoggerFactory.getLogger(DmpTouchedIntegrationEventHandlerImpl.class)); + + private final OutboxService outboxService; + + public DmpTouchedIntegrationEventHandlerImpl(OutboxService outboxService) { + this.outboxService = outboxService; + } + + @Override + public void handle(DmpTouchedIntegrationEvent event) { + OutboxIntegrationEvent message = new OutboxIntegrationEvent(); + message.setMessageId(UUID.randomUUID()); + message.setType(OutboxIntegrationEvent.DMP_TOUCH); + message.setEvent(event); + this.outboxService.publish(message); + } + +} diff --git a/dmp-backend/core/src/main/java/eu/eudat/service/description/DescriptionServiceImpl.java b/dmp-backend/core/src/main/java/eu/eudat/service/description/DescriptionServiceImpl.java index 09b28eaec..0cc62e25a 100644 --- a/dmp-backend/core/src/main/java/eu/eudat/service/description/DescriptionServiceImpl.java +++ b/dmp-backend/core/src/main/java/eu/eudat/service/description/DescriptionServiceImpl.java @@ -20,6 +20,8 @@ import eu.eudat.data.*; import eu.eudat.errorcode.ErrorThesaurusProperties; import eu.eudat.event.DescriptionTouchedEvent; import eu.eudat.event.EventBroker; +import eu.eudat.integrationevent.outbox.descriptiontouched.DescriptionTouchedIntegrationEvent; +import eu.eudat.integrationevent.outbox.descriptiontouched.DescriptionTouchedIntegrationEventHandler; import eu.eudat.integrationevent.outbox.notification.NotifyIntegrationEvent; import eu.eudat.integrationevent.outbox.notification.NotifyIntegrationEventHandler; import eu.eudat.model.*; @@ -94,22 +96,22 @@ public class DescriptionServiceImpl implements DescriptionService { private final ValidatorFactory validatorFactory; private final StorageFileProperties storageFileConfig; private final StorageFileService storageFileService; - + private final DescriptionTouchedIntegrationEventHandler descriptionTouchedIntegrationEventHandler; @Autowired public DescriptionServiceImpl( - EntityManager entityManager, - AuthorizationService authorizationService, - DeleterFactory deleterFactory, - BuilderFactory builderFactory, - ConventionService conventionService, - ErrorThesaurusProperties errors, - MessageSource messageSource, - EventBroker eventBroker, - QueryFactory queryFactory, - JsonHandlingService jsonHandlingService, - UserScope userScope, - XmlHandlingService xmlHandlingService, NotifyIntegrationEventHandler eventHandler, NotificationProperties notificationProperties, FileTransformerService fileTransformerService, ElasticService elasticService, ValidatorFactory validatorFactory, StorageFileProperties storageFileConfig, StorageFileService storageFileService) { + EntityManager entityManager, + AuthorizationService authorizationService, + DeleterFactory deleterFactory, + BuilderFactory builderFactory, + ConventionService conventionService, + ErrorThesaurusProperties errors, + MessageSource messageSource, + EventBroker eventBroker, + QueryFactory queryFactory, + JsonHandlingService jsonHandlingService, + UserScope userScope, + XmlHandlingService xmlHandlingService, NotifyIntegrationEventHandler eventHandler, NotificationProperties notificationProperties, FileTransformerService fileTransformerService, ElasticService elasticService, ValidatorFactory validatorFactory, StorageFileProperties storageFileConfig, StorageFileService storageFileService, DescriptionTouchedIntegrationEventHandler descriptionTouchedIntegrationEventHandler) { this.entityManager = entityManager; this.authorizationService = authorizationService; this.deleterFactory = deleterFactory; @@ -129,6 +131,7 @@ public class DescriptionServiceImpl implements DescriptionService { this.validatorFactory = validatorFactory; this.storageFileConfig = storageFileConfig; this.storageFileService = storageFileService; + this.descriptionTouchedIntegrationEventHandler = descriptionTouchedIntegrationEventHandler; } //region Persist @@ -202,6 +205,8 @@ public class DescriptionServiceImpl implements DescriptionService { //this.deleteOldFilesAndAddNew(datasetWizardModel, userInfo); //TODO this.eventBroker.emit(new DescriptionTouchedEvent(data.getId())); + this.descriptionTouchedIntegrationEventHandler.handle(DescriptionTouchedIntegrationEventHandler.buildEventFromPersistModel(model)); + this.elasticService.persistDescription(data); return this.builderFactory.builder(DescriptionBuilder.class).authorize(AuthorizationFlags.OwnerOrDmpAssociatedOrPermissionOrPublic).build(BaseFieldSet.build(fields, Description._id), data); } diff --git a/dmp-backend/core/src/main/java/eu/eudat/service/dmp/DmpServiceImpl.java b/dmp-backend/core/src/main/java/eu/eudat/service/dmp/DmpServiceImpl.java index 27da02938..3bdd9beb8 100644 --- a/dmp-backend/core/src/main/java/eu/eudat/service/dmp/DmpServiceImpl.java +++ b/dmp-backend/core/src/main/java/eu/eudat/service/dmp/DmpServiceImpl.java @@ -23,6 +23,7 @@ import eu.eudat.data.*; import eu.eudat.errorcode.ErrorThesaurusProperties; import eu.eudat.event.DmpTouchedEvent; import eu.eudat.event.EventBroker; +import eu.eudat.integrationevent.outbox.dmptouched.DmpTouchedIntegrationEventHandler; import eu.eudat.integrationevent.outbox.notification.NotifyIntegrationEvent; import eu.eudat.integrationevent.outbox.notification.NotifyIntegrationEventHandler; import eu.eudat.model.*; @@ -120,6 +121,8 @@ public class DmpServiceImpl implements DmpService { private final ElasticService elasticService; + private final DmpTouchedIntegrationEventHandler dmpTouchedIntegrationEventHandler; + @Autowired public DmpServiceImpl( EntityManager entityManager, @@ -140,7 +143,7 @@ public class DmpServiceImpl implements DmpService { ActionConfirmationService actionConfirmationService, FileTransformerService fileTransformerService, ValidatorFactory validatorFactory, - ElasticService elasticService) { + ElasticService elasticService, DmpTouchedIntegrationEventHandler dmpTouchedIntegrationEventHandler) { this.entityManager = entityManager; this.authorizationService = authorizationService; this.deleterFactory = deleterFactory; @@ -160,6 +163,7 @@ public class DmpServiceImpl implements DmpService { this.actionConfirmationService = actionConfirmationService; this.validatorFactory = validatorFactory; this.elasticService = elasticService; + this.dmpTouchedIntegrationEventHandler = dmpTouchedIntegrationEventHandler; } public Dmp persist(DmpPersist model, FieldSet fields) throws MyForbiddenException, MyValidationException, MyApplicationException, MyNotFoundException, InvalidApplicationException, IOException { @@ -178,6 +182,8 @@ public class DmpServiceImpl implements DmpService { this.eventBroker.emit(new DmpTouchedEvent(data.getId())); + this.dmpTouchedIntegrationEventHandler.handle(DmpTouchedIntegrationEventHandler.buildEventFromPersistModel(model)); + this.sendNotification(data); this.elasticService.persistDmp(data); diff --git a/dmp-backend/web/src/main/resources/config/queue.yml b/dmp-backend/web/src/main/resources/config/queue.yml index a506c176a..653e15d18 100644 --- a/dmp-backend/web/src/main/resources/config/queue.yml +++ b/dmp-backend/web/src/main/resources/config/queue.yml @@ -33,6 +33,8 @@ queue: tenant-user-invite-topic: tenant.invite user-touch-topic: user.touch user-removal-topic: user.remove + dmp-touch-topic: dmp.touch + description-touch-topic: description.touch what-you-know-about-me-completed-topic: whatyouknowaboutme.completed generate-file-topic: generate.file rabbitmq: