diff --git a/src/eddn/Monitor.py b/src/eddn/Monitor.py index dc7bb5d..dce2afb 100644 --- a/src/eddn/Monitor.py +++ b/src/eddn/Monitor.py @@ -229,7 +229,7 @@ class Monitor(Thread): # Duplicates? if Settings.RELAY_DUPLICATE_MAX_MINUTES: - if duplicate_messages.isDuplicated(json): + if duplicate_messages.is_duplicated(json): schema_id = 'DUPLICATE MESSAGE' c = db.cursor() diff --git a/src/eddn/Relay.py b/src/eddn/Relay.py index 3ff289d..83624dc 100644 --- a/src/eddn/Relay.py +++ b/src/eddn/Relay.py @@ -156,7 +156,7 @@ class Relay(Thread): # Handle duplicate message if Settings.RELAY_DUPLICATE_MAX_MINUTES: - if duplicate_messages.isDuplicated(json): + if duplicate_messages.is_duplicated(json): # We've already seen this message recently. Discard it. stats_collector.tally("duplicate") return diff --git a/src/eddn/core/DuplicateMessages.py b/src/eddn/core/DuplicateMessages.py index c3447b5..d2475c7 100644 --- a/src/eddn/core/DuplicateMessages.py +++ b/src/eddn/core/DuplicateMessages.py @@ -36,7 +36,7 @@ class DuplicateMessages(Thread): if self.caches[key] + timedelta(minutes=self.max_minutes) < max_time: del self.caches[key] - def isDuplicated(self, json): + def is_duplicated(self, json): with self.lock: # Test messages are never duplicate, would be a pain to wait for another test :D if re.search('test', json['$schemaRef'], re.I):