update

pubhook/on_publish.js

@@ -34,7 +34,7 @@ console.log('amqp://'+config.get('rabbitmq_username')+':'+config.get('rabbitmq_p
             if (data.topic.substring(0,5) == '$exec') {
             if (data.topic.substring(0,5) == '$exec') {
 console.log(555);
 console.log(555);
                 var stopic = data.topic.substr(6);
                 var stopic = data.topic.substr(6);
-                var a = data.topic.split('/');
+                var a = stopic.split('/');
                 var ptext = Buffer.from(data.payload, 'base64').toString();
                 var ptext = Buffer.from(data.payload, 'base64').toString();
 
 
 console.log(stopic);
 console.log(stopic);
@@ -50,7 +50,7 @@ console.log(a);
                                 "topic": stopic,
                                 "topic": stopic,
                                 "payload":ptext,
                                 "payload":ptext,
                                 "ts": Date.now(),
                                 "ts": Date.now(),
-                                "cid": data.client_id,
+                                "cid": data.client_id
                             }];
                             }];
 console.log(1111);
 console.log(1111);
 console.log(wfmsg);
 console.log(wfmsg);