reuse seneca instance

pubhook/on_publish.js

@@ -6,22 +6,35 @@ var LRU = require("lru-cache") ,
                 maxAge: 1000 * 60 * 5
                 });
 
-var client_wf = require('seneca')()
-  .use('seneca-amqp-transport')
-  .client({
+var senecaAMQP = require('seneca')().use('seneca-amqp-transport');
+var client_wf = senecaAMQP.client({
     type: 'amqp',
     pin: 'cmd:wf',
     url: 'amqp://'+config.get('rabbitmq_username')+':'+config.get('rabbitmq_password')+'@'+config.get('rabbitmq_host')+':'+config.get('rabbitmq_port')
-  });
-
-
-  var client_push = require('seneca')()
-  .use('seneca-amqp-transport')
-  .client({
+});
+var client_push = senecaAMQP.client({
     type: 'amqp',
     pin: 'cmd:push',
     url: 'amqp://'+config.get('rabbitmq_username')+':'+config.get('rabbitmq_password')+'@'+config.get('rabbitmq_host')+':'+config.get('rabbitmq_port')
-  });
+});
+
+
+// var client_wf = require('seneca')()
+//   .use('seneca-amqp-transport')
+//   .client({
+//     type: 'amqp',
+//     pin: 'cmd:wf',
+//     url: 'amqp://'+config.get('rabbitmq_username')+':'+config.get('rabbitmq_password')+'@'+config.get('rabbitmq_host')+':'+config.get('rabbitmq_port')
+//   });
+
+
+//   var client_push = require('seneca')()
+//   .use('seneca-amqp-transport')
+//   .client({
+//     type: 'amqp',
+//     pin: 'cmd:push',
+//     url: 'amqp://'+config.get('rabbitmq_username')+':'+config.get('rabbitmq_password')+'@'+config.get('rabbitmq_host')+':'+config.get('rabbitmq_port')
+//   });