Load the Plugin correctly and changed references to queue_ to queue

because file names are now Camel case

Author: Ryan McCaw

Console/Command/QueueShell.php

@@ -37,7 +37,7 @@ public function initialize() {
 
 		foreach (App::path('shells') as $path) {
 			$folder = new Folder($path . DS . 'Task');
-			$this->tasks = array_merge($this->tasks, $folder->find('Queue.*\.php'));
+			$this->tasks = array_merge($this->tasks, $folder->find('queue.*\.php'));
 		}
 		// strip the extension fom the found task(file)s
 		foreach ($this->tasks as &$task) {
@@ -110,8 +110,8 @@ public function add() {
 		} else {
 			if (in_array($this->args[0], $this->taskNames)) {
 				$this->{$this->args[0]}->add();
-			} elseif (in_array('queue_' . $this->args[0], $this->taskNames)) {
-				$this->{'queue_' . $this->args[0]}->add();
+			} elseif (in_array('queue' . $this->args[0], $this->taskNames)) {
+				$this->{'queue' . $this->args[0]}->add();
 			} else {
 				$this->out('Error:');
 				$this->out('       Task not found: ' . $this->args[0], 2);
@@ -152,7 +152,7 @@ public function runworker() {
 			} else {
 				if ($data !== false) {
 					$this->out('Running Job of type "' . $data['jobtype'] . '"');
-					$taskname = 'queue_' . strtolower($data['jobtype']);
+					$taskname = 'queue' . $data['jobtype'];
 					$jobData = unserialize($data['data']);
 					if (!$this->{$taskname}->canRun($jobData)) {
 						$this->QueuedTask->requeueJob($data['id'], $this->getTaskConf($taskname, 'timeout'));

Console/Command/Task/QueueExampleTask.php

@@ -19,7 +19,7 @@ class queueExampleTask extends Shell {
 	 * @var array
 	 */
 	public $uses = array(
-		'Queue.QueuedTask'
+		'CakephpQueue.QueuedTask'
 	);
 
 	/**

Console/Command/Task/QueueExecuteTask.php

@@ -19,7 +19,7 @@ class queueExecuteTask extends Shell {
 	 * @var array
 	 */
 	public $uses = array(
-		'Queue.QueuedTask'
+		'CakephpQueue.QueuedTask'
 	);
 
 	/**

Model/QueuedTask.php

@@ -114,7 +114,7 @@ public function requestJob($capabilities, $group = null) {
 		// generate the task specific conditions.
 		foreach ($capabilities as $task) {
 			$tmp = array(
-				'jobtype' => str_replace('queue_', '', $task['name']),
+				'jobtype' => str_replace('queue', '', $task['name']),
 				'AND' => array(
 					array(
 						'OR' => array(
@@ -138,6 +138,7 @@ public function requestJob($capabilities, $group = null) {
 		}
 		// First, find a list of a few of the oldest unfinished tasks.
 		$data = $this->find('all', $findConf);
+
 		if (is_array($data) && count($data) > 0) {
 			// generate a list of their ID's
 			foreach ($data as $item) {

Model/QueuedTaskResponse.php

@@ -6,18 +6,18 @@
  
 In some controller:
 
-var $uses = array('Queue.QueuedTask', 'Queue.QueuedTaskResponse');
+var $uses = array('CakephpQueue.QueuedTask', 'CakephpQueue.QueuedTaskResponse');
 
 function action() {
 	$key = $this->QueuedTaskResponse->generate();
-	$this->QueuedTask->createJob('some_task', array('response_key' => $key));
+	$this->QueuedTask->createJob('SomeTask', array('response_key' => $key));
 	$response = $this->QueuedTaskResponse->getValue($key, true);
 	$this->set('response', $response);
 }
 
 In your queue task:
 
-var $uses = array('Queue.QueuedTaskResponse');
+var $uses = array('CakephpQueue.QueuedTaskResponse');
 function run($data) {
 	$this->QueuedTaskResponse->setValue($data['response_key'], 'Return value');
 }

Test/cases/models/queued_task.test.php

@@ -7,7 +7,7 @@
  * @link http://github.com/MSeven/cakephp_queue
  */
 
-App::import('Model', 'Queue.QueuedTask');
+App::import('Model', 'CakephpQueue.QueuedTask');
 
 class TestQueuedTask extends QueuedTask {
 	public $name = 'TestQueuedTask';