diff --git a/lib/index.js b/lib/index.js
index 465d2f8..25ec926 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -104,8 +104,8 @@ InsightAPI.prototype.start = function(callback) {
   this._bus.on('block/block', this.transactionEventHandler.bind(this));
   this._bus.subscribe('block/block');
 
-  this._bus.on('mempool/transaction', this.blockEventHandler.bind(this));
-  this._bus.subscribe('mempool/transaction');
+  this._bus.on('p2p/transaction', this.blockEventHandler.bind(this));
+  this._bus.subscribe('p2p/transaction');
 
   callback();