From 424469b9ffee8cf2845fa43dc2f18048bbb3fd2c Mon Sep 17 00:00:00 2001 From: AnthorNet Date: Mon, 8 Jun 2015 12:37:30 +0200 Subject: [PATCH] Removed duplicate on test messages --- src/eddn/core/DuplicateMessages.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/eddn/core/DuplicateMessages.py b/src/eddn/core/DuplicateMessages.py index 3bb2e2b..039f1c1 100644 --- a/src/eddn/core/DuplicateMessages.py +++ b/src/eddn/core/DuplicateMessages.py @@ -5,6 +5,8 @@ from threading import Lock, Thread from time import sleep import hashlib import zlib +import re + import simplejson from eddn.conf.Settings import Settings, loadConfig @@ -35,6 +37,10 @@ class DuplicateMessages(Thread): message = zlib.decompress(message) message = simplejson.loads(message) + # Test messages are not duplicate + if re.search('test', message['$schemaRef'], re.I): + return False + if message['header']['gatewayTimestamp']: del message['header']['gatewayTimestamp'] # Prevent dupe with new timestamp ^^ if message['message']['timestamp']: