Browse Source

Adds tests for #2767

Ask Solem 9 years ago
parent
commit
04d81bb70e
1 changed files with 13 additions and 0 deletions
  1. 13 0
      celery/tests/events/test_events.py

+ 13 - 0
celery/tests/events/test_events.py

@@ -218,6 +218,19 @@ class test_EventReceiver(AppCase):
         r = self.app.events.Receiver(Mock(), accept={'app/foo'})
         self.assertEqual(r.accept, {'app/foo'})
 
+    def test_event_queue_prefix__default(self):
+        r = self.app.events.Receiver(Mock())
+        self.assertTrue(r.queue.name.startswith('celeryev.'))
+
+    def test_event_queue_prefix__setting(self):
+        self.app.conf.event_queue_prefix = 'eventq'
+        r = self.app.events.Receiver(Mock())
+        self.assertTrue(r.queue.name.startswith('eventq.'))
+
+    def test_event_queue_prefix__argument(self):
+        r = self.app.events.Receiver(Mock(), queue_prefix='fooq')
+        self.assertTrue(r.queue.name.startswith('fooq.'))
+
     def test_catch_all_event(self):
 
         message = {'type': 'world-war'}