pgq.consumer: dont allow big seeking around

1 files changed, 2 insertions, 0 deletions

diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index bd49dccf..8160f1d1 100644
--- a/python/pgq/consumer.py
+++ b/python/pgq/consumer.py
@@ -334,6 +334,8 @@ class SerialConsumer(Consumer):
             return False
 
         if prev_tick < dst_tick:
+            if dst_tick - prev_tick > 5:
+                 raise Exception('Difference too big, skipping dangerous')
             self.log.warning('Got tick %d, dst has %d - skipping' % (prev_tick, dst_tick))
             return True
         else: