diff --git a/feeds.module b/feeds.module
index 9982823469d320f958d1e8e141c6ccf8984ed581..f7bdaf964eff457085fdddcd65948a32d35bf4c4 100644
--- a/feeds.module
+++ b/feeds.module
@@ -18,6 +18,8 @@ define('FEEDS_EXPIRE_NEVER', -1);
 // An object is not persistent at all. Compare to EXPORT_IN_DATABASE OR
 // EXPORT_IN_CODE.
 define('FEEDS_EXPORT_NONE', 0x0);
+// The Drupal Queue FeedsScheduler may use for scheduling importing or expiry.
+define('FEEDS_SCHEDULER_QUEUE', 'feeds_queue');
 
 
 /**
@@ -38,7 +40,7 @@ function feeds_cron() {
  */
 function feeds_cron_queue_info() {
   $queues = array();
-  $queues['feeds_queue'] = array(
+  $queues[FEEDS_SCHEDULER_QUEUE] = array(
     'worker callback' => 'feeds_scheduler_work',
     'time' => variable_get('feeds_worker_time', 60),
   );
diff --git a/includes/FeedsScheduler.inc b/includes/FeedsScheduler.inc
index 7b9376455315dad0350fe56fddaff5dbced29073..bc3ffa8ede73d10e71f3aac2ba3412a31f74302e 100644
--- a/includes/FeedsScheduler.inc
+++ b/includes/FeedsScheduler.inc
@@ -111,7 +111,11 @@ class FeedsScheduler implements IFeedsScheduler {
     // Get feeds configuration, check whether drupal_queue is present and set
     // parameters accordingly.
     if ($importers = feeds_importer_load_all()) {
-      $use_queue = module_exists('drupal_queue');
+
+      if ($use_queue = module_exists('drupal_queue')) {
+        drupal_queue_include();
+        $queue = drupal_queue_get(FEEDS_SCHEDULER_QUEUE);
+      }
       $num = variable_get('feeds_schedule_num', $use_queue ? 200 : 5);
       $num = $num ? $num : 1;