rref #5367

rref #5366 ref #66 ref #65
zetaops · Jun 28, 2016 · b3f8e53 · b3f8e53
1 parent 0c17f7a
commit b3f8e53
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 7 deletions.
diff --git a/zengine/client_queue.py b/zengine/client_queue.py
@@ -54,9 +54,11 @@ def get_sess_id(self):
         return self.sess_id
 
     def send_to_queue(self, message=None, json_message=None):
-        log.debug("Sending following message to %s queue:\n%s " % (
-            self.sess_id, json_message or json.dumps(message)))
-        self.get_channel().publish(exchange=self.user_id or '',
+        exchange = self.user_id or ''
+        log.debug("Sending following message to %s queue, \"%s\" exchange:\n%s " % (
+            self.sess_id, exchange, json_message or json.dumps(message)))
+
+        self.get_channel().publish(exchange=exchange,
                                          routing_key=self.sess_id,
                                          body=json_message or json.dumps(message))
 

diff --git a/zengine/messaging/lib.py b/zengine/messaging/lib.py
@@ -106,7 +106,8 @@ def get_role(self, role_id):
     def full_name(self):
         return self.username
 
-    def bind_private_channel(self, sess_id):
+    @classmethod
+    def bind_private_channel(cls, sess_id):
         mq_channel = self._connect_mq()
         mq_channel.queue_bind(exchange='prv_%s' % self.key, queue=sess_id)
 

diff --git a/zengine/tornado_server/queue_manager.py b/zengine/tornado_server/queue_manager.py
@@ -190,10 +190,10 @@ def register_websocket(self, sess_id, ws):
     def inform_disconnection(self, sess_id):
         self.in_channel.basic_publish(exchange='input_exc',
                                       routing_key=sess_id,
-                                      body=json_encode({
+                                      body=json_encode(dict(data={
                                           'view': 'mark_offline_user',
                                           'sess_id': sess_id
-                                      }))
+                                      })))
 
     def unregister_websocket(self, sess_id):
         try:

diff --git a/zengine/wf_daemon.py b/zengine/wf_daemon.py
@@ -166,7 +166,7 @@ def handle_message(self, ch, method, properties, body):
                 raise
             err = traceback.format_exc()
             output = {'error': self._prepare_error_msg(err), "code": 500}
-            log.exception("Worker error occurred")
+            log.exception("Worker error occurred with messsage body:\n%s" % body)
         if 'callbackID' in input:
             output['callbackID'] = input['callbackID']
         log.info("OUTPUT for %s: %s" % (sessid, output))