summaryrefslogtreecommitdiff
path: root/sleekxmpp/plugins
diff options
context:
space:
mode:
authorLance Stout <lancestout@gmail.com>2012-07-24 02:39:54 -0700
committerLance Stout <lancestout@gmail.com>2012-07-24 02:39:54 -0700
commit3e43b36a9d70801d90a6b09046f93879f2e29b89 (patch)
tree758b0f60cb569605a91900fcbfd10d7bc364a243 /sleekxmpp/plugins
parent352ee2f2fd6458a46e046ecaedb78addd5d6ac20 (diff)
downloadslixmpp-3e43b36a9d70801d90a6b09046f93879f2e29b89.tar.gz
slixmpp-3e43b36a9d70801d90a6b09046f93879f2e29b89.tar.bz2
slixmpp-3e43b36a9d70801d90a6b09046f93879f2e29b89.tar.xz
slixmpp-3e43b36a9d70801d90a6b09046f93879f2e29b89.zip
Standardize importing of queue class.
This will make it easier to enable gevent support.
Diffstat (limited to 'sleekxmpp/plugins')
-rw-r--r--sleekxmpp/plugins/xep_0047/stream.py7
1 files changed, 2 insertions, 5 deletions
diff --git a/sleekxmpp/plugins/xep_0047/stream.py b/sleekxmpp/plugins/xep_0047/stream.py
index 49f56f36..b49a077b 100644
--- a/sleekxmpp/plugins/xep_0047/stream.py
+++ b/sleekxmpp/plugins/xep_0047/stream.py
@@ -1,11 +1,8 @@
import socket
import threading
import logging
-try:
- import queue
-except ImportError:
- import Queue as queue
+from sleekxmpp.util import Queue
from sleekxmpp.exceptions import XMPPError
@@ -33,7 +30,7 @@ class IBBytestream(object):
self.stream_in_closed = threading.Event()
self.stream_out_closed = threading.Event()
- self.recv_queue = queue.Queue()
+ self.recv_queue = Queue()
self.send_window = threading.BoundedSemaphore(value=self.window_size)
self.window_ids = set()