|
111 | 111 | use Symfony\Component\Messenger\Handler\BatchHandlerInterface;
|
112 | 112 | use Symfony\Component\Messenger\MessageBus;
|
113 | 113 | use Symfony\Component\Messenger\MessageBusInterface;
|
| 114 | +use Symfony\Component\Messenger\Middleware\LockMiddleware; |
114 | 115 | use Symfony\Component\Messenger\Middleware\RouterContextMiddleware;
|
115 | 116 | use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
|
116 | 117 | use Symfony\Component\Messenger\Transport\TransportFactoryInterface as MessengerTransportFactoryInterface;
|
@@ -1986,6 +1987,10 @@ private function registerLockConfiguration(array $config, ContainerBuilder $cont
|
1986 | 1987 | {
|
1987 | 1988 | $loader->load('lock.php');
|
1988 | 1989 |
|
| 1990 | + if (!class_exists(LockMiddleware::class)) { |
| 1991 | + $container->removeDefinition('messenger.middleware.lock_middleware'); |
| 1992 | + } |
| 1993 | + |
1989 | 1994 | foreach ($config['resources'] as $resourceName => $resourceStores) {
|
1990 | 1995 | if (0 === \count($resourceStores)) {
|
1991 | 1996 | continue;
|
@@ -2124,13 +2129,16 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
|
2124 | 2129 | ['id' => 'reject_redelivered_message_middleware'],
|
2125 | 2130 | ['id' => 'dispatch_after_current_bus'],
|
2126 | 2131 | ['id' => 'failed_message_processing_middleware'],
|
2127 |
| - ['id' => 'lock_middleware'], |
2128 | 2132 | ],
|
2129 | 2133 | 'after' => [
|
2130 | 2134 | ['id' => 'send_message'],
|
2131 | 2135 | ['id' => 'handle_message'],
|
2132 | 2136 | ],
|
2133 | 2137 | ];
|
| 2138 | + if (class_exists(LockMiddleware::class)) { |
| 2139 | + $defaultMiddleware['before'][] = ['id' => 'lock_middleware']; |
| 2140 | + } |
| 2141 | + |
2134 | 2142 | foreach ($config['buses'] as $busId => $bus) {
|
2135 | 2143 | $middleware = $bus['middleware'];
|
2136 | 2144 |
|
|
0 commit comments