working push, pull, and subscribe using axon

Stephenitis · Jun 20, 2013 · 2af644b · 2af644b
1 parent 7a40aa6
commit 2af644b
Show file tree

Hide file tree

Showing 51 changed files with 3,032 additions and 0 deletions.
diff --git a/node-program.js b/node-program.js
@@ -0,0 +1,32 @@
+var axon = require('axon')
+  , sock = axon.socket('pull');
+sock.bind(3000);
+// sock.connect(3000);
+
+sock.on('message', function(msg){
+  console.log("************************************");
+  console.log(msg.toString());
+});
+
+
+var axon = require('axon')
+  , sockPush = axon.socket('push');
+
+sockPush.connect('tcp://000.000.0.000:3000');
+console.log('push server started');
+
+setInterval(function(){
+  sockPush.send();
+  console.log("************************************");
+  console.log("omgz STEPHEN IS PUSHING")
+}, 500);
+
+var axon = require('axon')
+  , sockSub = axon.socket('sub');
+
+sockSub.connect("tcp://000.000.0.00:3000");
+
+sockSub.on('message', function(msg){
+  console.log("************************************");
+  console.log(msg.toString());
+});
diff --git a/node_modules/axon/.npmignore b/node_modules/axon/.npmignore
diff --git a/node_modules/axon/History.md b/node_modules/axon/History.md
diff --git a/node_modules/axon/Makefile b/node_modules/axon/Makefile