aws_sqs.module

<?php

/**
 * @file
 * AWS SQS module functions.
 */

/**
 * Implements hook_menu().
 */
function aws_sqs_menu() {
  $items['admin/config/system/aws-queue'] = array(
    'route_name' => 'aws_sqs.settings',
    'title' => 'Amazon SQS Settings',
    'description' => 'Configure your Amazon SQS Settings.',
  );

  return $items;
}


/**
 * Implements hook_queue_info().
 *
 * This hook is used by queue_ui (and other modules)
 * to discover non SystemQueue based queues.
 */
function aws_sqs_queue_info() {
  // Import variables from settings.php
  global $conf;

  $queues = array();

  $blacklist = array(
    'aws_sqs_default_queue',
    'aws_sqs_aws_key',
    'aws_sqs_aws_secret',
    'aws_sqs_region',
    'aws_sqs_waittimeseconds',
    'aws_sqs_enable',
  );

  foreach(variable_initialize($conf) as $key => $value) {
    if (substr($key, 0, 7) == 'aws_sqs' && !in_array($key, $blacklist)) {
      $name = substr($key, 8);
      $queues[$name] = array('title' => str_replace('_', ' ', $name));
    }
  }

  return $queues;
}


/*function aws_sqs_test() {
  // initialize the queue
  $queue = Drupal::queue('update_fetch_tasks');
  // Create the queue
  $queue->createQueue();
  // Get some data
  $item = array('test', '1', '2', '3');
  // Add the data to the queue
  $queue->createItem($item);
  // Fetch the item from the queue
  $item = $queue->claimItem();
  $queue->deleteItem($item);
  //drush_print_r($item);
}*/