From 45d9e0e5c236aa9ac20d2c0e9b33dd5dc4057782 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Thu, 22 Dec 2016 13:36:13 +0100
Subject: [PATCH] +tests
---
LICENSE | 2 +-
tests/test_cluster.py | 14 +++++++-------
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/LICENSE b/LICENSE
index f054be6..2aee442 100644
--- a/LICENSE
+++ b/LICENSE
@@ -1,6 +1,6 @@
The MIT License (MIT)
-Copyright (c) 2016 Piotr MaĹlanka
+Copyright (c) 2016 DMS Serwis s.c.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
diff --git a/tests/test_cluster.py b/tests/test_cluster.py
index 251c494..3b93354 100644
--- a/tests/test_cluster.py
+++ b/tests/test_cluster.py
@@ -25,13 +25,13 @@ class MyTestCase(unittest.TestCase):
self.assertIsInstance(p, MessageReceived)
self.assertEquals(p.message.body, b'what the fuck')
-# def test_consumer_cancelled_on_queue_deletion(self):
-# myq = Queue('myqueue', exclusive=True)
-#
-# self.amqp.consume(myq)
-# self.amqp.delete_queue(myq)
-#
-# self.assertIsInstance(self.amqp.drain(wait=10), ConsumerCancelled)
+ def test_consumer_cancelled_on_queue_deletion(self):
+ myq = Queue('myqueue', exclusive=True)
+
+ self.amqp.consume(myq)
+ self.amqp.delete_queue(myq)
+
+ self.assertIsInstance(self.amqp.drain(wait=10), ConsumerCancelled)
def test_consumer_cancelled_on_consumer_cancel(self):
myq = Queue('myqueue', exclusive=True)
--
GitLab