Avoid creating qpid connection twice in initialization
In current logic, class impl_qpid.Connnection constructor calls method connection_create twice indirectly. Let us avoid this. Change-Id: I7618cf3506d857579dc37b338690d05179ba272d
This commit is contained in:
parent
1e8ef86626
commit
39d1dde432
@ -440,6 +440,7 @@ class Connection(object):
|
|||||||
if not qpid_messaging:
|
if not qpid_messaging:
|
||||||
raise ImportError("Failed to import qpid.messaging")
|
raise ImportError("Failed to import qpid.messaging")
|
||||||
|
|
||||||
|
self.connection = None
|
||||||
self.session = None
|
self.session = None
|
||||||
self.consumers = {}
|
self.consumers = {}
|
||||||
self.consumer_thread = None
|
self.consumer_thread = None
|
||||||
@ -463,7 +464,6 @@ class Connection(object):
|
|||||||
self.brokers = params['qpid_hosts']
|
self.brokers = params['qpid_hosts']
|
||||||
self.username = params['username']
|
self.username = params['username']
|
||||||
self.password = params['password']
|
self.password = params['password']
|
||||||
self.connection_create(self.brokers[0])
|
|
||||||
self.reconnect()
|
self.reconnect()
|
||||||
|
|
||||||
def connection_create(self, broker):
|
def connection_create(self, broker):
|
||||||
@ -494,7 +494,7 @@ class Connection(object):
|
|||||||
delay = 1
|
delay = 1
|
||||||
while True:
|
while True:
|
||||||
# Close the session if necessary
|
# Close the session if necessary
|
||||||
if self.connection.opened():
|
if self.connection is not None and self.connection.opened():
|
||||||
try:
|
try:
|
||||||
self.connection.close()
|
self.connection.close()
|
||||||
except qpid_exceptions.ConnectionError:
|
except qpid_exceptions.ConnectionError:
|
||||||
|
Loading…
Reference in New Issue
Block a user