X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=yardstick%2Fnetwork_services%2Fnfvi%2Fcollectd.py;h=e0027bbcb8b891ce185581a5d53d70ebdeb61ec2;hb=ad825953bd2a48425ee064b3f30f4ee606df9313;hp=f2c9d40a70f5dbfb97a4e08a4177835f3cfae5e0;hpb=2b441865e1e2f06b27ed8ab81c8559a9e5c50c58;p=yardstick.git

diff --git a/yardstick/network_services/nfvi/collectd.py b/yardstick/network_services/nfvi/collectd.py
index f2c9d40a7..e0027bbcb 100644
--- a/yardstick/network_services/nfvi/collectd.py
+++ b/yardstick/network_services/nfvi/collectd.py
@@ -35,6 +35,7 @@ class AmqpConsumer(object):
         self._consumer_tag = None
         self._url = amqp_url
         self._queue = queue
+        self._queue.cancel_join_thread()
 
     def connect(self):
         """ connect to amqp url """