messaging-bundle/WebmozartsMessagingBundle.php at master · webmozarts/messaging-bundle · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
<?php

/*
 * This file is part of the Webmozarts Messaging Bundle.
 *
 * (c) 2016-2019 Bernhard Schussek <bernhard.schussek@webmozarts.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Webmozarts\MessagingBundle;

use Webmozarts\MessagingBundle\Annotation\MetadataResolver\AsyncMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\ChannelMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\DelegatingMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\QualifierMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\RetryMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\RoutingKeyMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\RunAsMetadataResolver;
use Webmozarts\MessagingBundle\Annotation\MetadataResolver\ThrottleMetadataResolver;
use Webmozarts\MessagingBundle\Channel\Factory\AnnotationBasedChannelFactory;
use Webmozarts\MessagingBundle\DependencyInjection\Compiler\AddHandlerDescriptorsPass;
use Webmozarts\MessagingBundle\DependencyInjection\Compiler\InjectTaggedServicesPass;
use Webmozarts\MessagingBundle\DependencyInjection\Compiler\RegisterQualifiersPass;
use Webmozarts\MessagingBundle\DependencyInjection\WebmozartsMessagingExtension;
use Webmozarts\MessagingBundle\MetadataResolver\AnnotationBasedMetadataResolver;
use Doctrine\Common\Annotations\AnnotationReader;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\HttpKernel\Bundle\Bundle;

class WebmozartsMessagingBundle extends Bundle
{
    public function getContainerExtension()
    {
        return new WebmozartsMessagingExtension('webmozarts_messaging');
    }

    public function build(ContainerBuilder $container)
    {
        $annotationReader = new AnnotationReader();
        $annotationMetadataResolver = new DelegatingMetadataResolver([
            new AsyncMetadataResolver(),
            new ChannelMetadataResolver(),
            new QualifierMetadataResolver(),
            new RetryMetadataResolver(),
            new RoutingKeyMetadataResolver(),
            new RunAsMetadataResolver(),
            new ThrottleMetadataResolver(),
        ]);
        $metadataResolver = new AnnotationBasedMetadataResolver(
            $annotationReader,
            $annotationMetadataResolver
        );
        $channelFactory = new AnnotationBasedChannelFactory($annotationReader);

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.command_bus',
            'webmozarts_messaging.command_bus_middleware',
            0
        ));

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.event_bus',
            'webmozarts_messaging.event_bus_middleware',
            0
        ));

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.event_bus.aggregates_recorded_messages',
            'webmozarts_messaging.event_recorder',
            0
        ));

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.command_bus.handler_invoker',
            'webmozarts_messaging.command_handler_invoker_middleware',
            0
        ));

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.event_bus.handler_invoker',
            'webmozarts_messaging.event_handler_invoker_middleware',
            0
        ));

        $container->addCompilerPass(new AddHandlerDescriptorsPass(
            $metadataResolver,
            $channelFactory,
            'webmozarts_messaging.command_bus.predefined_handler_descriptor_resolver',
            'webmozarts_messaging.channel_registry',
            'webmozarts_messaging.command_handler',
            'handle'
        ));

        $container->addCompilerPass(new AddHandlerDescriptorsPass(
            $metadataResolver,
            $channelFactory,
            'webmozarts_messaging.event_bus.predefined_handler_descriptor_resolver',
            'webmozarts_messaging.channel_registry',
            'webmozarts_messaging.event_handler',
            'when'
        ));

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.asynchronous.command_bus',
            'webmozarts_messaging.asynchronous_command_bus_middleware',
            0
        ));

        $container->addCompilerPass(new InjectTaggedServicesPass(
            'webmozarts_messaging.asynchronous.event_bus',
            'webmozarts_messaging.asynchronous_event_bus_middleware',
            0
        ));

        $container->addCompilerPass(new RegisterQualifiersPass(
            'webmozarts_messaging.asynchronous.gateway',
            'registerQualifier',
            'webmozarts_messaging.asynchronous_message_bus',
            'qualifier'
        ));
    }
}