diff --git a/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/DaprTopic.java b/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/DaprTopic.java index 0e4f4d8..c750bfd 100644 --- a/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/DaprTopic.java +++ b/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/DaprTopic.java @@ -12,6 +12,8 @@ public enum DaprTopic { MEDIA_RECORD_FILE_CREATED("media-record-file-created"), + MEDIA_RECORD_DELETED("media-record-deleted"), + ITEM_CHANGED("item-changed"); private final String topic; diff --git a/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/TopicPublisher.java b/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/TopicPublisher.java index 1c3decb..e48ffbf 100644 --- a/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/TopicPublisher.java +++ b/src/main/java/de/unistuttgart/iste/meitrex/common/dapr/TopicPublisher.java @@ -114,4 +114,12 @@ public void notifyUserProgressUpdated(final UserProgressUpdatedEvent userProgres public void notifyMediaRecordFileCreated(final MediaRecordFileCreatedEvent mediaRecordFileCreatedEvent) { publishEvent(mediaRecordFileCreatedEvent, DaprTopic.MEDIA_RECORD_FILE_CREATED); } + + /** + * Method to notify when a media record has been deleted. + * @param mediaRecordDeletedEvent of the deleted media record + */ + public void notifyMediaRecordDeleted(final MediaRecordDeletedEvent mediaRecordDeletedEvent) { + publishEvent(mediaRecordDeletedEvent, DaprTopic.MEDIA_RECORD_DELETED); + } }