3
3
* Copyright © Magento, Inc. All rights reserved.
4
4
* See COPYING.txt for license details.
5
5
*/
6
+
6
7
namespace Enqueue \Magento2 \Console ;
7
8
8
- use Enqueue \Symfony \Client \ConsumeMessagesCommand ;
9
- use Enqueue \Symfony \Client \Meta \QueuesCommand ;
10
- use Enqueue \Symfony \Client \Meta \TopicsCommand ;
11
- use Enqueue \Symfony \Client \ProduceMessageCommand ;
12
- use Enqueue \Symfony \Client \SetupBrokerCommand ;
13
9
/**
14
10
* Provides list of commands to be available for uninstalled application
15
11
*/
@@ -70,22 +66,6 @@ public function __construct(
70
66
$ this ->consumeMessagesCommandFactory = $ consumeMessagesCommand ;
71
67
}
72
68
73
- /**
74
- * Gets list of command classes
75
- *
76
- * @return string[]
77
- */
78
- private function getCommandsClasses ()
79
- {
80
- return [
81
- SetupBrokerCommand::class,
82
- ProduceMessageCommand::class,
83
- TopicsCommand::class,
84
- ConsumeMessagesCommand::class,
85
- QueuesCommand::class,
86
- ];
87
- }
88
-
89
69
/**
90
70
* @inheritdoc
91
71
*/
@@ -96,24 +76,18 @@ public function getCommands()
96
76
$ this ->enqueueManager ->bindProcessors ();
97
77
$ client = $ this ->enqueueManager ->getClient ();
98
78
99
- foreach ($ this ->getCommandsClasses () as $ class ) {
100
- if (class_exists ($ class )) {
101
- $ commands [] = $ this ->setupBrokerCommandFactory ->create (['driver ' => $ client ->getDriver ()]);
102
- $ commands [] = $ this ->produceMessageCommandFactory ->create (['producer ' => $ client ->getProducer ()]);
103
- $ commands [] = $ this ->queuesCommandFactory ->create (['queueRegistry ' => $ client ->getQueueMetaRegistry ()]);
104
- $ commands [] = $ this ->topicsCommandFactory ->create (['topicRegistry ' => $ client ->getTopicMetaRegistry ()]);
105
- $ commands [] = $ this ->consumeMessagesCommandFactory ->create (
106
- [
107
- 'consumer ' => $ client ->getQueueConsumer (),
108
- 'processor ' => $ client ->getDelegateProcessor (),
109
- 'queueMetaRegistry ' => $ client ->getQueueMetaRegistry (),
110
- 'driver ' => $ client ->getDriver ()
111
- ]
112
- );
113
- } else {
114
- throw new \Exception ('Class ' . $ class . ' does not exist ' );
115
- }
116
- }
79
+ $ commands [] = $ this ->setupBrokerCommandFactory ->create (['driver ' => $ client ->getDriver ()]);
80
+ $ commands [] = $ this ->produceMessageCommandFactory ->create (['producer ' => $ client ->getProducer ()]);
81
+ $ commands [] = $ this ->queuesCommandFactory ->create (['queueRegistry ' => $ client ->getQueueMetaRegistry ()]);
82
+ $ commands [] = $ this ->topicsCommandFactory ->create (['topicRegistry ' => $ client ->getTopicMetaRegistry ()]);
83
+ $ commands [] = $ this ->consumeMessagesCommandFactory ->create (
84
+ [
85
+ 'consumer ' => $ client ->getQueueConsumer (),
86
+ 'processor ' => $ client ->getDelegateProcessor (),
87
+ 'queueMetaRegistry ' => $ client ->getQueueMetaRegistry (),
88
+ 'driver ' => $ client ->getDriver ()
89
+ ]
90
+ );
117
91
118
92
return $ commands ;
119
93
}
0 commit comments