Merge pull request #3 from johannessteu/queue-name

dfeyer · web-flow · commit 3d0ab460ec82 · 2016-07-28T14:34:16.000+02:00
TASK: Show queue name when jobs are created
diff --git a/Classes/Flowpack/ElasticSearch/ContentRepositoryQueueIndexer/Command/NodeIndexQueueCommandController.php b/Classes/Flowpack/ElasticSearch/ContentRepositoryQueueIndexer/Command/NodeIndexQueueCommandController.php
@@ -92,10 +92,11 @@ public function buildCommand($workspace = NULL) {
 			$this->indexWorkspace($workspace, $indexPostfix);
 		}
 		$updateAliasJob = new UpdateAliasJob($indexPostfix);
-		$this->jobManager->queue('Flowpack.ElasticSearch.ContentRepositoryQueueIndexer', $updateAliasJob);
+		$queueName = 'Flowpack.ElasticSearch.ContentRepositoryQueueIndexer';
+		$this->jobManager->queue($queueName, $updateAliasJob);
 
 		$this->outputLine();
-		$this->outputLine('Indexing jobs created with success ...');
+		$this->outputLine(sprintf('Indexing jobs created for queue %s with success ...', $queueName));
 	}
 
 	/**

Original file line number	Diff line number	Diff line change
`@@ -92,10 +92,11 @@ public function buildCommand($workspace = NULL) {`
`92`	`92`	`$this->indexWorkspace($workspace, $indexPostfix);`
`93`	`93`	`}`
`94`	`94`	`$updateAliasJob = new UpdateAliasJob($indexPostfix);`
`95`		`- $this->jobManager->queue('Flowpack.ElasticSearch.ContentRepositoryQueueIndexer', $updateAliasJob);`
	`95`	`+ $queueName = 'Flowpack.ElasticSearch.ContentRepositoryQueueIndexer';`
	`96`	`+ $this->jobManager->queue($queueName, $updateAliasJob);`
`96`	`97`
`97`	`98`	`$this->outputLine();`
`98`		`- $this->outputLine('Indexing jobs created with success ...');`
	`99`	`+ $this->outputLine(sprintf('Indexing jobs created for queue %s with success ...', $queueName));`
`99`	`100`	`}`
`100`	`101`
`101`	`102`	`/**`