diff --git a/src/Prooph/ServiceBus/Message/DefaultQueueFactory.php b/src/Prooph/ServiceBus/Message/DefaultQueueFactory.php
index f625cac..0aeb217 100644
--- 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;