You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2010/07/13 21:07:22 UTC
svn commit: r963825 - in /qpid/trunk/qpid/python/qpid/messaging: driver.py
util.py
Author: rhs
Date: Tue Jul 13 19:07:22 2010
New Revision: 963825
URL: http://svn.apache.org/viewvc?rev=963825&view=rev
Log:
eliminate spurious error logging and reconnect attempts
Modified:
qpid/trunk/qpid/python/qpid/messaging/driver.py
qpid/trunk/qpid/python/qpid/messaging/util.py
Modified: qpid/trunk/qpid/python/qpid/messaging/driver.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging/driver.py?rev=963825&r1=963824&r2=963825&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/driver.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/driver.py Tue Jul 13 19:07:22 2010
@@ -463,7 +463,7 @@ class Driver:
def dispatch(self):
try:
if self._transport is None:
- if self.connection._connected:
+ if self.connection._connected and not self.connection.error:
self.connect()
else:
self.engine.dispatch()
Modified: qpid/trunk/qpid/python/qpid/messaging/util.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging/util.py?rev=963825&r1=963824&r2=963825&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/util.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/util.py Tue Jul 13 19:07:22 2010
@@ -21,6 +21,7 @@
Add-on utilities for the L{qpid.messaging} API.
"""
+from qpid.messaging import *
from logging import getLogger
from threading import Thread
@@ -33,7 +34,10 @@ def auto_fetch_reconnect_urls(conn):
def main():
while True:
- msg = rcv.fetch()
+ try:
+ msg = rcv.fetch()
+ except LinkClosed:
+ return
set_reconnect_urls(conn, msg)
ssn.acknowledge(msg, sync=False)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org