Skip to content

Commit bbd17fb

Browse files
committed
Fix queue name setting
1 parent 188e222 commit bbd17fb

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

controllers/IndexController.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -374,7 +374,7 @@ protected function _dispatchImportTask($csvImport, $method = null)
374374
$csvConfig = $this->_getPluginConfig();
375375

376376
$jobDispatcher = Zend_Registry::get('job_dispatcher');
377-
$jobDispatcher->setQueueName(CsvImport_ImportTask::QUEUE_NAME);
377+
$jobDispatcher->setQueueNameLongRunning(CsvImport_ImportTask::QUEUE_NAME);
378378
try {
379379
$jobDispatcher->sendLongRunning('CsvImport_ImportTask',
380380
array(

models/CsvImport/ImportTask.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
*/
99
class CsvImport_ImportTask extends Omeka_Job_AbstractJob
1010
{
11-
const QUEUE_NAME = 'csv_import_imports';
11+
const QUEUE_NAME = 'imports';
1212
const METHOD_START = 'start';
1313
const METHOD_UNDO = 'undo';
1414

@@ -39,7 +39,7 @@ public function perform()
3939
call_user_func(array($import, $this->_method));
4040

4141
if ($import->isQueued() || $import->isQueuedUndo()) {
42-
$this->_dispatcher->setQueueName(self::QUEUE_NAME);
42+
$this->_dispatcher->setQueueNameLongRunning(self::QUEUE_NAME);
4343
$this->_dispatcher->sendLongRunning(__CLASS__,
4444
array(
4545
'importId' => $import->id,

0 commit comments

Comments
 (0)