diff --git a/app/core/processor.py b/app/core/processor.py
index 0321ee7..3f5f2fc 100644
--- a/app/core/processor.py
+++ b/app/core/processor.py
@@ -397,7 +397,7 @@ def rss(token, onstart=False):
 def mail(to_email, subject, message):
 
     zmsg = {
-        'topic': 'email:sendmail',
+        'topic': 'email:send',
         'to': to_email,
         'subject': subject,
         'content': message
diff --git a/app/interface/zclient.py b/app/interface/zclient.py
index 63c18d7..3650b79 100644
--- a/app/interface/zclient.py
+++ b/app/interface/zclient.py
@@ -15,7 +15,7 @@ context = zmq.Context()
 
 def process(message):
     data = json.loads(message)
-    if data['topic'] == 'email:newmail':
+    if data['topic'] == 'email:mail':
         logger.info('newmail => {}'.format(data))
         processor.enqueue({'request': 'new_mail', 'data': data})