diff --git a/steps/espocrm_webhooks/document_create_webhook_api_step.py b/steps/espocrm_webhooks/document_create_webhook_api_step.py
index 705ea2e..deccdc5 100644
--- a/steps/espocrm_webhooks/document_create_webhook_api_step.py
+++ b/steps/espocrm_webhooks/document_create_webhook_api_step.py
@@ -10,13 +10,13 @@ from motia import FlowContext, http, ApiRequest, ApiResponse
 
 
 config = {
-    "name": "EspoCRM Document Create Webhook",
+    "name": "VMH Webhook Document Create",
     "description": "Empfängt Create-Webhooks von EspoCRM für Document Entities",
-    "flows": ["espocrm-documents"],
+    "flows": ["vmh-documents"],
     "triggers": [
-        http("POST", "/api/espocrm/document/create")
+        http("POST", "/vmh/webhook/document/create")
     ],
-    "enqueues": ["espocrm.document.create"],
+    "enqueues": ["vmh.document.create"],
 }
 
 
@@ -153,7 +153,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
         # Emit events für Queue-Processing (Deduplizierung erfolgt im Event-Handler via Lock)
         for entity_id in entity_ids:
             await ctx.enqueue({
-                'topic': 'espocrm.document.create',
+                'topic': 'vmh.document.create',
                 'data': {
                     'entity_id': entity_id,
                     'action': 'create',
@@ -161,7 +161,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
                     'timestamp': datetime.datetime.now().isoformat()
                 }
             })
-            ctx.logger.info(f"✅ Event emittiert: espocrm.document.create für ID {entity_id}")
+            ctx.logger.info(f"✅ Event emittiert: vmh.document.create für ID {entity_id}")
         
         ctx.logger.info("\n" + "=" * 80)
         ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN")
diff --git a/steps/espocrm_webhooks/document_delete_webhook_api_step.py b/steps/espocrm_webhooks/document_delete_webhook_api_step.py
index f9a33f9..6c77dfd 100644
--- a/steps/espocrm_webhooks/document_delete_webhook_api_step.py
+++ b/steps/espocrm_webhooks/document_delete_webhook_api_step.py
@@ -10,13 +10,13 @@ from motia import FlowContext, http, ApiRequest, ApiResponse
 
 
 config = {
-    "name": "EspoCRM Document Delete Webhook",
+    "name": "VMH Webhook Document Delete",
     "description": "Empfängt Delete-Webhooks von EspoCRM für Document Entities",
-    "flows": ["espocrm-documents"],
+    "flows": ["vmh-documents"],
     "triggers": [
-        http("POST", "/api/espocrm/document/delete")
+        http("POST", "/vmh/webhook/document/delete")
     ],
-    "enqueues": ["espocrm.document.delete"],
+    "enqueues": ["vmh.document.delete"],
 }
 
 
@@ -130,7 +130,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
         # Emit events für Queue-Processing
         for entity_id in entity_ids:
             await ctx.enqueue({
-                'topic': 'espocrm.document.delete',
+                'topic': 'vmh.document.delete',
                 'data': {
                     'entity_id': entity_id,
                     'action': 'delete',
@@ -138,7 +138,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
                     'timestamp': datetime.datetime.now().isoformat()
                 }
             })
-            ctx.logger.info(f"✅ Event emittiert: espocrm.document.delete für ID {entity_id}")
+            ctx.logger.info(f"✅ Event emittiert: vmh.document.delete für ID {entity_id}")
         
         ctx.logger.info("\n" + "=" * 80)
         ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN")
diff --git a/steps/espocrm_webhooks/document_update_webhook_api_step.py b/steps/espocrm_webhooks/document_update_webhook_api_step.py
index c4dc91e..ebb01b7 100644
--- a/steps/espocrm_webhooks/document_update_webhook_api_step.py
+++ b/steps/espocrm_webhooks/document_update_webhook_api_step.py
@@ -10,13 +10,13 @@ from motia import FlowContext, http, ApiRequest, ApiResponse
 
 
 config = {
-    "name": "EspoCRM Document Update Webhook",
+    "name": "VMH Webhook Document Update",
     "description": "Empfängt Update-Webhooks von EspoCRM für Document Entities",
-    "flows": ["espocrm-documents"],
+    "flows": ["vmh-documents"],
     "triggers": [
-        http("POST", "/api/espocrm/document/update")
+        http("POST", "/vmh/webhook/document/update")
     ],
-    "enqueues": ["espocrm.document.update"],
+    "enqueues": ["vmh.document.update"],
 }
 
 
@@ -152,7 +152,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
         # Emit events für Queue-Processing
         for entity_id in entity_ids:
             await ctx.enqueue({
-                'topic': 'espocrm.document.update',
+                'topic': 'vmh.document.update',
                 'data': {
                     'entity_id': entity_id,
                     'action': 'update',
@@ -160,7 +160,7 @@ async def handler(request: ApiRequest, ctx: FlowContext[Any]) -> ApiResponse:
                     'timestamp': datetime.datetime.now().isoformat()
                 }
             })
-            ctx.logger.info(f"✅ Event emittiert: espocrm.document.update für ID {entity_id}")
+            ctx.logger.info(f"✅ Event emittiert: vmh.document.update für ID {entity_id}")
         
         ctx.logger.info("\n" + "=" * 80)
         ctx.logger.info(f"✅ WEBHOOK VERARBEITUNG ABGESCHLOSSEN")