svn commit: r912595 - /qpid/trunk/qpid/python/qpid/messaging/driver.py

[rh...@apache.org]

Author: rhs
Date: Mon Feb 22 14:50:27 2010
New Revision: 912595

URL: http://svn.apache.org/viewvc?rev=912595&view=rev
Log:
removed redundant state flag

Modified:
    qpid/trunk/qpid/python/qpid/messaging/driver.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=912595&r1=912594&r2=912595&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/driver.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/driver.py Mon Feb 22 14:50:27 2010
@@ -303,7 +303,6 @@
     self.reset()
 
   def reset(self):
-    self._opening = False
     self._closing = False
     self._connected = False
     self._attachments = {}
@@ -586,7 +585,7 @@
 
   def dispatch(self):
     try:
-      if self._socket is None and self.connection._connected and not self._opening:
+      if self._socket is None and self.connection._connected:
         self.connect()
       elif self._socket is not None and not self.connection._connected and not self._closing:
         self.disconnect()
@@ -615,7 +614,6 @@
       self._host = 0
       self._retrying = False
       self._buf += struct.pack(HEADER, "AMQP", 1, 1, 0, 10)
-      self._opening = True
     except socket.error, e:
       self._host = (self._host + 1) % len(self._hosts)
       self._error(e, True)



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org