diff --git a/src/context/service/database/Events.py b/src/context/service/database/Events.py
index 8794032b126249d4955aace2bba2d294fee88f24..36774a5170ba20914555b0adc47a5c2faa592799 100644
--- a/src/context/service/database/Events.py
+++ b/src/context/service/database/Events.py
@@ -77,8 +77,9 @@ def notify_event_policy_rule(messagebroker : MessageBroker, event_type : EventTy
     notify_event(messagebroker, EventTopicEnum.POLICY_RULE, event_type, {'policyrule_id': policyrule_id})
 
 def consume_events(
-    messagebroker : MessageBroker, topic_names : Set[str], consume_timeout : float = CONSUME_TIMEOUT
+    messagebroker : MessageBroker, topic_enums : Set[EventTopicEnum], consume_timeout : float = CONSUME_TIMEOUT
 ) -> Iterator:
+    topic_names = [topic_enum.value for topic_enum in topic_enums]
     for message in messagebroker.consume(topic_names, consume_timeout=consume_timeout):
         event_class = TOPIC_TO_EVENTCLASS.get(message.topic)
         if event_class is None: