diff options
author | Lance Stout <lancestout@gmail.com> | 2011-06-20 16:27:25 -0700 |
---|---|---|
committer | Lance Stout <lancestout@gmail.com> | 2011-06-20 16:27:25 -0700 |
commit | 774e0f2022f1ee318dc57c0008ea6cf1ddadce29 (patch) | |
tree | 578eb962a707b5a60dfc503449829515bdc0cf54 /sleekxmpp | |
parent | d1e12cd46fffb56bc7fbe9f1043d01f714356722 (diff) | |
parent | d8d9e8df16c07bd13bbac72e4445a2930407b244 (diff) | |
download | slixmpp-774e0f2022f1ee318dc57c0008ea6cf1ddadce29.tar.gz slixmpp-774e0f2022f1ee318dc57c0008ea6cf1ddadce29.tar.bz2 slixmpp-774e0f2022f1ee318dc57c0008ea6cf1ddadce29.tar.xz slixmpp-774e0f2022f1ee318dc57c0008ea6cf1ddadce29.zip |
Merge branch 'develop' into roster
Diffstat (limited to 'sleekxmpp')
-rw-r--r-- | sleekxmpp/stanza/message.py | 2 | ||||
-rw-r--r-- | sleekxmpp/xmlstream/xmlstream.py | 13 |
2 files changed, 9 insertions, 6 deletions
diff --git a/sleekxmpp/stanza/message.py b/sleekxmpp/stanza/message.py index cb3d344c..3518fc7a 100644 --- a/sleekxmpp/stanza/message.py +++ b/sleekxmpp/stanza/message.py @@ -97,7 +97,7 @@ class Message(RootStanza): clear -- Indicates if existing content should be removed before replying. Defaults to True. """ - StanzaBase.reply(self) + StanzaBase.reply(self, clear) if self['type'] == 'groupchat': self['to'] = self['to'].bare diff --git a/sleekxmpp/xmlstream/xmlstream.py b/sleekxmpp/xmlstream/xmlstream.py index 5bc71f04..6282c8d0 100644 --- a/sleekxmpp/xmlstream/xmlstream.py +++ b/sleekxmpp/xmlstream/xmlstream.py @@ -944,13 +944,14 @@ class XMLStream(object): func -- The event handler to execute. args -- Arguments to the event handler. """ + orig = copy.copy(args[0]) try: func(*args) except Exception as e: error_msg = 'Error processing event handler: %s' log.exception(error_msg % str(func)) - if hasattr(args[0], 'exception'): - args[0].exception(e) + if hasattr(orig, 'exception'): + orig.exception(e) def _event_runner(self): """ @@ -973,6 +974,7 @@ class XMLStream(object): etype, handler = event[0:2] args = event[2:] + orig = copy.copy(args[0]) if etype == 'stanza': try: @@ -980,7 +982,7 @@ class XMLStream(object): except Exception as e: error_msg = 'Error processing stream handler: %s' log.exception(error_msg % handler.name) - args[0].exception(e) + orig.exception(e) elif etype == 'schedule': try: log.debug('Scheduled event: %s' % args) @@ -989,6 +991,7 @@ class XMLStream(object): log.exception('Error processing scheduled task') elif etype == 'event': func, threaded, disposable = handler + orig = copy.copy(args[0]) try: if threaded: x = threading.Thread( @@ -1001,8 +1004,8 @@ class XMLStream(object): except Exception as e: error_msg = 'Error processing event handler: %s' log.exception(error_msg % str(func)) - if hasattr(args[0], 'exception'): - args[0].exception(e) + if hasattr(orig, 'exception'): + orig.exception(e) elif etype == 'quit': log.debug("Quitting event runner thread") return False |