diff --git a/app/workers/mail_store_worker.py b/app/workers/mail_store_worker.py
index 3de8379..9f554a0 100644
--- a/app/workers/mail_store_worker.py
+++ b/app/workers/mail_store_worker.py
@@ -14,8 +14,7 @@ from app.models import Message, Task, TaskStatus
 class MailStoreWorker(BaseWorker):
     routing_key = "mail.store"
 
-    async def handle(self, task) -> dict:
-        payload = task.job.payload  # payload liegt auf dem Job
+    async def process(self, payload: dict, **meta) -> dict:
         raw = base64.b64decode(payload["raw_eml_b64"])
         mailbox_id = UUID(payload["mailbox_id"])
 
@@ -68,3 +67,11 @@ class MailStoreWorker(BaseWorker):
 
         return result
 
+async def main():
+    worker =MailStoreWorker(routing_key("MailSend", "ImportMessage"), worker_id="mail-import-1")
+    await worker.run()
+
+if __name__ == "__main__":
+    import asyncio as _a
+    _a.run(main())
+