Close #19: Add check that QueueFactory is used in right context

prooph · Jun 28, 2014 · de51aa0 · de51aa0
1 parent 22b94c1
commit de51aa0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/Prooph/ServiceBus/Message/DefaultQueueFactory.php b/src/Prooph/ServiceBus/Message/DefaultQueueFactory.php
@@ -34,6 +34,7 @@ public function canCreateServiceWithName(ServiceLocatorInterface $serviceLocator
     {
         try {
             \Assert\that($requestedName)->notEmpty()->string();
+            \Assert\that($serviceLocator)->isInstanceOf("Prooph\ServiceBus\Service\QueueManager");
             return true;
         } catch (\InvalidArgumentException $ex) {
             return false;