From 7472e7a5817587bf94a510aea5cca2d71f66844b Mon Sep 17 00:00:00 2001
From: sancar <sancar@hazelcast.com>
Date: Tue, 21 Feb 2017 15:24:15 +0300
Subject: [PATCH] ignore raised Empty on reactor queue since queue is also
 consumed when timer is cancelled

---
 hazelcast/reactor.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/hazelcast/reactor.py b/hazelcast/reactor.py
index a92de21b5d..8eea6968d6 100644
--- a/hazelcast/reactor.py
+++ b/hazelcast/reactor.py
@@ -6,7 +6,7 @@
 import sys
 import threading
 import time
-from Queue import PriorityQueue
+from Queue import PriorityQueue, Empty
 from collections import deque
 
 from hazelcast.connection import Connection, BUFFER_SIZE
@@ -55,7 +55,10 @@ def _check_timers(self):
                 return
 
             if timer.check_timer(now):
-                self._timers.get_nowait()
+                try:
+                    self._timers.get_nowait()
+                except Empty:
+                    pass
             else:
                 return