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

diff --git a/yardstick/network_services/nfvi/collectd.py b/yardstick/network_services/nfvi/collectd.py
index ea80e4ff8..e0027bbcb 100644
--- a/yardstick/network_services/nfvi/collectd.py
+++ b/yardstick/network_services/nfvi/collectd.py
@@ -11,7 +11,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-""" AMQP Consumer senario definition """
+""" AMQP Consumer scenario definition """
 
 from __future__ import absolute_import
 from __future__ import print_function
@@ -28,12 +28,14 @@ class AmqpConsumer(object):
     ROUTING_KEY = 'collectd'
 
     def __init__(self, amqp_url, queue):
+        super(AmqpConsumer, self).__init__()
         self._connection = None
         self._channel = None
         self._closing = False
         self._consumer_tag = None
         self._url = amqp_url
         self._queue = queue
+        self._queue.cancel_join_thread()
 
     def connect(self):
         """ connect to amqp url """