diff --git a/handler/transactions.py b/handler/transactions.py
index 4c9ba7c..5b7ca1c 100644
--- a/handler/transactions.py
+++ b/handler/transactions.py
@@ -516,6 +516,7 @@ class Transactions(object):
     def write_to_es(self, msgtype, cast):
         cast["type"] = msgtype
         cast["ts"] = str(datetime.now().isoformat())
+        cast["xtype"] = "tx"
         self.es.index(index=settings.ES.Index, document=cast)
 
     def get_remaining(self):