diff --git a/config/blockchain.js b/config/blockchain.js
new file mode 100644
index 0000000..0b4d065
--- /dev/null
+++ b/config/blockchain.js
@@ -0,0 +1,3 @@
+var WebSocket = require('ws');
+var ws = new WebSocket('wss://ws.chain.com/v2/notifications');
+module.exports.blockchain = ws;
diff --git a/worker.js b/worker.js
index 9c7a7e2..a3bce87 100644
--- a/worker.js
+++ b/worker.js
@@ -3,4 +3,6 @@ Sails.load(function(err, sails) {
   var market = require('./worker/market.js');
   // push continuous rate updates to redis
   market.contRate();
+  var trans = require('./worker/transactions.js');
+  trans.trans();
 });
diff --git a/worker/transactions.js b/worker/transactions.js
new file mode 100644
index 0000000..559ffcd
--- /dev/null
+++ b/worker/transactions.js
@@ -0,0 +1,12 @@
+var ws = sails.config.blockchain;
+module.exports.trans = function(){
+  var log = sails.log;
+  ws.on('open', function() {
+      ws.send(JSON.stringify({type: 'new-transaction', block_chain: 'bitcoin'}));
+  });
+  ws.on('message', function(ev) {
+    var x = JSON.parse(ev);
+    log.silly('New Transaction',x);
+  });
+
+};