diff options
author | René 'Necoro' Neumann <necoro@necoro.net> | 2009-08-15 04:28:53 +0200 |
---|---|---|
committer | René 'Necoro' Neumann <necoro@necoro.net> | 2009-08-15 04:28:53 +0200 |
commit | 4feddaea01a755bcabc331a7a20836bc319f8b3e (patch) | |
tree | 5eaf7f377d0a6520ac97fea9a096c9aca7dfddd8 /portato/listener.py | |
parent | 5355e5ad97e9c235c0cb1aecabae3b4fd38eea2a (diff) | |
download | portato-4feddaea01a755bcabc331a7a20836bc319f8b3e.tar.gz portato-4feddaea01a755bcabc331a7a20836bc319f8b3e.tar.bz2 portato-4feddaea01a755bcabc331a7a20836bc319f8b3e.zip |
First try of own mq-module
Diffstat (limited to 'portato/listener.py')
-rw-r--r-- | portato/listener.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/portato/listener.py b/portato/listener.py index 1c12b00..4666269 100644 --- a/portato/listener.py +++ b/portato/listener.py @@ -32,13 +32,13 @@ class Listener (object): @ivar _send: sender socket @type _send: int""" - def set_recv (self, mq): + def set_recv (self, _mq): - self._mq = mq + self._mq = _mq while True: try: - msg, type = self._mq.receive(block = True) + msg, type = self._mq.receive() data = msg.split("\0") debug("Listener received: %s", data) @@ -76,17 +76,17 @@ class Listener (object): n.set_urgency(int(urgency)) n.show() - def set_send (self, mq = None): - if mq is None: + def set_send (self, _mq = None): + if _mq is None: warning(_("Listener has not been started.")) self._mq = None else: - from . import sysv_ipc as ipc + from . import mq - self._mq = ipc.MessageQueue(mq) + self._mq = mq.MessageQueue(_mq) def __send (self, string): - self._mq.send(string, block = True) + self._mq.send(string) def send_notify (self, base = "", descr = "", icon = "", urgency = None): if self._mq is None: |