diff --git a/lib/storage.js b/lib/storage.js
index <HASH>..<HASH> 100644
--- a/lib/storage.js
+++ b/lib/storage.js
@@ -65,6 +65,9 @@ Storage.prototype._createIndexes = function() {
     address: 1,
   });
   this.db.collection(collections.EMAIL_QUEUE).createIndex({
+    id: 1,
+  });
+  this.db.collection(collections.EMAIL_QUEUE).createIndex({
     notificationId: 1,
   });
   this.db.collection(collections.CACHE).createIndex({
@@ -628,7 +631,7 @@ Storage.prototype.storeActiveAddresses = function(walletId, addresses, cb) {
 };
 
 // --------         ---------------------------  Total
-//           > Time >                  
+//           > Time >
 //                       ^to     <=  ^from
 //                       ^fwdIndex  =>  ^end
 Storage.prototype.getTxHistoryCache = function(walletId, from, to, cb) {
adding needed index for email_queue.id