add on_publish.js

pubhook/config/custom-environment-variables.json

 {
-	"authserv_host" : "AUTH_SERVICE_HOST",
-	"authserv_port" : "AUTH_SERVICE_PORT"
+	"rabbitmq_host"     : "RABBITMQ_HOST",
+	"rabbitmq_port"     : "RABBITMQ_PORT",
+	"rabbitmq_username" : "RABBITMQ_USERNAME",
+	"rabbitmq_password" : "RABBITMQ_PASSWORD"
 }

pubhook/on_publish.js

@@ -6,6 +6,15 @@ var LRU = require("lru-cache") ,
                 maxAge: 1000 * 60 * 5
                 });
 
+var client = require('seneca')()
+  .use('seneca-amqp-transport')
+  .client({
+    type: 'amqp',
+    pin: 'cmd:writefeed,feedid:serialno',
+    url: 'amqp://'+config.get('rabbitmq_username')+':'+config.get('rabbitmq_password')+'@'+config.get('rabbitmq_host')+':'+config.get('rabbitmq_port')
+  });
+
+
 module.exports = function(options={}) {
     return function(req, res, next) {
 
@@ -13,6 +22,28 @@ module.exports = function(options={}) {
             if (options.debug) {
                 console.log('on_publish-------------');
                 console.log(req.body);
+
+                var data = req.body;
+
+                if (data.topic.substring(0,5) == '$exec') {
+                    var a = data.topic.split('/');
+                    var p = data.payload.split(':');
+
+                    switch (a[1]) {
+                        case 'wf'        :
+                        case 'writefeed' :
+                                var data = [{
+                                    "name": a[2],
+                                    "timestamp": Date.now(),
+                                    "data":data.payload,
+ 
+                                    "value": p[0],
+                                    "tags":{"attr":p[1]}
+                                }];
+                                break;
+                    }
+                }
+
             }
 
             var topic = req.body.topic;