diff --git a/report_sql.py b/report_sql.py
index 8577f4b..4b1b609 100644
--- a/report_sql.py
+++ b/report_sql.py
@@ -73,7 +73,7 @@ class reportClient(NetstringReceiver):
         if len(datalist) > 9:
             event['duration'] = datalist[9]
         
-        if event['event'] == 'END':
+        if event['event'] == 'END' and event['trx'] == RX:
             
             while not self.db.is_connected():
                 self.db.reconnect()