diff --git a/zaqar/storage/mongodb/subscriptions.py b/zaqar/storage/mongodb/subscriptions.py
index 665a7fc3b..ce6837bc9 100644
--- a/zaqar/storage/mongodb/subscriptions.py
+++ b/zaqar/storage/mongodb/subscriptions.py
@@ -47,8 +47,7 @@ class SubscriptionController(base.Subscription):
     def __init__(self, *args, **kwargs):
         super(SubscriptionController, self).__init__(*args, **kwargs)
         self._collection = self.driver.subscriptions_database.subscriptions
-        queue_col = self.driver.control_driver.queues_database.queues
-        self._queue_collection = queue_col
+        self._queue_ctrl = self.driver.queue_controller
         self._collection.ensure_index(SUBSCRIPTIONS_INDEX, unique=True)
 
     @utils.raises_conn_error
@@ -95,12 +94,9 @@ class SubscriptionController(base.Subscription):
         now = timeutils.utcnow_ts()
         ttl = int(ttl)
         expires = now + ttl
-        source_query = {'p_q': utils.scope_queue_name(source, project)}
-        target_source = self._queue_collection.find_one(
-            source_query, projection={'m': 1, '_id': 0})
 
-        if target_source is None:
-            raise errors.QueueDoesNotExist(target_source, project)
+        if not self._queue_ctrl.exists(source, project):
+            raise errors.QueueDoesNotExist(source, project)
         try:
             subscription_id = self._collection.insert({'s': source,
                                                        'u': subscriber,