File tree Expand file tree Collapse file tree 5 files changed +12
-14
lines changed Expand file tree Collapse file tree 5 files changed +12
-14
lines changed Original file line number Diff line number Diff line change 1515use Hyperf \AsyncQueue \AnnotationJob ;
1616use Hyperf \AsyncQueue \Driver \DriverFactory ;
1717use Hyperf \AsyncQueue \Environment ;
18- use Hyperf \Di \Annotation \Aspect ;
1918use Hyperf \Di \Aop \AbstractAspect ;
2019use Hyperf \Di \Aop \ProceedingJoinPoint ;
2120use Psr \Container \ContainerInterface ;
2221
23- #[Aspect]
2422class AsyncQueueAspect extends AbstractAspect
2523{
2624 public array $ annotations = [
Original file line number Diff line number Diff line change 1212namespace Hyperf \AsyncQueue \Command ;
1313
1414use Hyperf \AsyncQueue \Driver \DriverFactory ;
15- use Hyperf \Command \Annotation \Command ;
1615use Hyperf \Command \Command as HyperfCommand ;
1716use Psr \Container \ContainerInterface ;
1817use Symfony \Component \Console \Input \InputArgument ;
1918use Symfony \Component \Console \Input \InputOption ;
2019
21- #[Command]
2220class FlushFailedMessageCommand extends HyperfCommand
2321{
2422 protected ContainerInterface $ container ;
Original file line number Diff line number Diff line change 1212namespace Hyperf \AsyncQueue \Command ;
1313
1414use Hyperf \AsyncQueue \Driver \DriverFactory ;
15- use Hyperf \Command \Annotation \Command ;
1615use Hyperf \Command \Command as HyperfCommand ;
1716use Psr \Container \ContainerInterface ;
1817use Symfony \Component \Console \Input \InputArgument ;
1918
20- #[Command]
2119class InfoCommand extends HyperfCommand
2220{
2321 protected ContainerInterface $ container ;
Original file line number Diff line number Diff line change 1212namespace Hyperf \AsyncQueue \Command ;
1313
1414use Hyperf \AsyncQueue \Driver \DriverFactory ;
15- use Hyperf \Command \Annotation \Command ;
1615use Hyperf \Command \Command as HyperfCommand ;
1716use Psr \Container \ContainerInterface ;
1817use Symfony \Component \Console \Input \InputArgument ;
1918use Symfony \Component \Console \Input \InputOption ;
2019
21- #[Command]
2220class ReloadFailedMessageCommand extends HyperfCommand
2321{
2422 protected ContainerInterface $ container ;
Original file line number Diff line number Diff line change 1111 */
1212namespace Hyperf \AsyncQueue ;
1313
14+ use Hyperf \AsyncQueue \Aspect \AsyncQueueAspect ;
15+ use Hyperf \AsyncQueue \Command \FlushFailedMessageCommand ;
16+ use Hyperf \AsyncQueue \Command \InfoCommand ;
17+ use Hyperf \AsyncQueue \Command \ReloadFailedMessageCommand ;
18+
1419class ConfigProvider
1520{
1621 public function __invoke (): array
1722 {
1823 return [
19- 'annotations ' => [
20- 'scan ' => [
21- 'paths ' => [
22- __DIR__ ,
23- ],
24- ],
24+ 'aspects ' => [
25+ AsyncQueueAspect::class,
26+ ],
27+ 'commands ' => [
28+ FlushFailedMessageCommand::class,
29+ InfoCommand::class,
30+ ReloadFailedMessageCommand::class,
2531 ],
2632 'publish ' => [
2733 [
You can’t perform that action at this time.
0 commit comments