Fix InterruptedException references

jasonrbriggs · Jun 14, 2015 · 3362834 · 3362834
1 parent c863743
commit 3362834
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/stomp/transport.py b/stomp/transport.py
@@ -325,7 +325,7 @@ def __read(self):
             try:
                 try:
                     c = self.receive()
-                except InterruptedException:
+                except exception.InterruptedException:
                     log.debug("socket read interrupted, restarting")
                     continue
                 c = decode(c)
@@ -605,7 +605,7 @@ def receive(self):
             _, e, _ = sys.exc_info()
             if get_errno(e) in (errno.EAGAIN, errno.EINTR):
                 log.debug("socket read interrupted, restarting")
-                raise InterruptedException()
+                raise exception.InterruptedException()
             raise