From 3362834a7bc0d93c3424b302d322d35a681de2c4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ville=20Skytt=C3=A4?= Date: Sun, 14 Jun 2015 12:38:32 +0300 Subject: [PATCH] Fix InterruptedException references --- stomp/transport.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/stomp/transport.py b/stomp/transport.py index ba2e0fa8..f426fd8d 100644 --- 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