--no commit message

--no commit message

package.json

@@ -14,6 +14,7 @@
   "dependencies": {
     "amqplib": "^0.4.2",
     "async": "^2.0.1",
+    "axon": "^2.0.3",
     "body-parser": "^1.15.2",
     "bson": "^0.5.6",
     "buffalo": "^0.1.3",

test/axon/bind.js

+// var axon = require('axon');
+// var sock = axon.socket('push');
+//
+// sock.bind('tcp://0.0.0.0:3333')
+// console.log('push server started');
+//
+// sock.on('disconnect',function(dat){
+//   console.log(dat._peername);
+// })
+//
+// sock.on('connect',function(dat){
+//   console.log('connect');
+//   console.log(dat._peername);
+// })
+//
+//
+// var i=0;
+// setInterval(function(){
+//   var t = {'t':'hello','seq':i++}
+//   sock.send(t);
+// }, 1500);
+
+var axon = require('axon');
+var sock = axon.socket('rep');
+
+sock.bind('tcp://0.0.0.0:3333')
+
+sock.on('message', function(img, reply){
+  // resize the image
+  console.log('receive');
+  var rep = img;
+  rep.note = 'rep';
+  reply(rep);
+});

test/axon/conn.js

+// var axon = require('axon');
+// var sock = axon.socket('pull');
+//
+// sock.connect('tcp://127.0.0.1:3333');
+//
+// sock.on('message', function(msg){
+//   console.log(msg);
+// });
+
+var axon = require('axon');
+var sock = axon.socket('req');
+
+sock.connect('tcp://127.0.0.1:3333');
+
+var img = {
+  't' : 'hello'
+}
+sock.send(img, function(res){
+  console.log(res);
+});