diff --git a/LICENSE b/LICENSE index f054be642eb029401ab214741746e5efd538ef09..2aee4425774c25f03d50bd7e219bf82485e49ae8 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 251c49420f95b58af46c9e2c987da76878f5de9b..3b933543f64c7b296f9420d6315fa900c73bdd1a 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)