Skip to content

Commit 41bd2f2

Browse files
committed
TASK: Minor cleanups
1 parent 2b5370d commit 41bd2f2

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

Classes/Command/NodeIndexQueueCommandController.php

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,8 @@
4141
*/
4242
class NodeIndexQueueCommandController extends CommandController
4343
{
44-
const BATCH_QUEUE_NAME = 'Flowpack.ElasticSearch.ContentRepositoryQueueIndexer';
45-
const LIVE_QUEUE_NAME = 'Flowpack.ElasticSearch.ContentRepositoryQueueIndexer.Live';
44+
protected const BATCH_QUEUE_NAME = 'Flowpack.ElasticSearch.ContentRepositoryQueueIndexer';
45+
public const LIVE_QUEUE_NAME = 'Flowpack.ElasticSearch.ContentRepositoryQueueIndexer.Live';
4646

4747
/**
4848
* @Flow\Inject
@@ -108,6 +108,7 @@ class NodeIndexQueueCommandController extends CommandController
108108
* @throws \Flowpack\ElasticSearch\ContentRepositoryAdaptor\Exception
109109
* @throws \Flowpack\ElasticSearch\Exception
110110
* @throws \Neos\Flow\Http\Exception
111+
* @throws \Exception
111112
*/
112113
public function buildCommand(string $workspace = null): void
113114
{
@@ -138,7 +139,7 @@ public function buildCommand(string $workspace = null): void
138139
$updateAliasJob = new UpdateAliasJob($indexPostfix);
139140
$this->jobManager->queue(self::BATCH_QUEUE_NAME, $updateAliasJob);
140141

141-
$this->outputLine("Indexing jobs created for queue %s with success ...", [self::BATCH_QUEUE_NAME]);
142+
$this->outputLine('Indexing jobs created for queue %s with success ...', [self::BATCH_QUEUE_NAME]);
142143
$this->outputSystemReport();
143144
$this->outputLine();
144145
}

Classes/UpdateAliasJob.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public function execute(QueueInterface $queue, Message $message): bool
8888
$this->cleanupOldIndices();
8989
}
9090

91-
$this->logger->info(sprintf('Index was switched successfully tp %s', $this->indexPostfix), LogEnvironment::fromMethodName(__METHOD__));
91+
$this->logger->info(sprintf('Index was switched successfully to %s', $this->indexPostfix), LogEnvironment::fromMethodName(__METHOD__));
9292
} else {
9393
$this->logger->error(sprintf('Index %s was not switched due to %s failed batches in the current queue"', $this->indexPostfix, $queue->countFailed()), LogEnvironment::fromMethodName(__METHOD__));
9494
}

0 commit comments

Comments
 (0)