Release 1.241.0

Author: dgafka

packages/Amqp/composer.json

@@ -42,7 +42,7 @@
     },
     "require": {
         "ext-amqp": "*",
-        "ecotone/enqueue": "~1.240.1",
+        "ecotone/enqueue": "~1.241.0",
         "enqueue/amqp-ext": "^0.10.18",
         "enqueue/dsn": "^0.10.4",
         "enqueue/enqueue": "^0.10.0"
@@ -65,7 +65,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-main": "1.240.1-dev"
+            "dev-main": "1.241.0-dev"
         },
         "ecotone": {
             "repository": "amqp"
@@ -86,7 +86,7 @@
                 "description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
             }
         },
-        "release-time": "2024-12-07 13:28:31"
+        "release-time": "2024-12-28 19:05:37"
     },
     "config": {
         "allow-plugins": {

packages/Dbal/composer.json

@@ -33,7 +33,7 @@
         }
     },
     "require": {
-        "ecotone/enqueue": "~1.240.1",
+        "ecotone/enqueue": "~1.241.0",
         "enqueue/dbal": "^0.10.17",
         "doctrine/dbal": "^2.12.0|^3.0"
     },
@@ -45,7 +45,7 @@
         "doctrine/cache": "^1.0.0|^2.0",
         "doctrine/annotations": "^1.13|^2.0",
         "wikimedia/composer-merge-plugin": "^2.1",
-        "ecotone/jms-converter": "~1.240.1",
+        "ecotone/jms-converter": "~1.241.0",
         "symfony/expression-language": "^6.0|^7.0"
     },
     "scripts": {
@@ -58,7 +58,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-main": "1.240.1-dev"
+            "dev-main": "1.241.0-dev"
         },
         "ecotone": {
             "repository": "dbal"
@@ -79,7 +79,7 @@
                 "description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
             }
         },
-        "release-time": "2024-12-07 13:28:31"
+        "release-time": "2024-12-28 19:05:37"
     },
     "config": {
         "allow-plugins": {

packages/Ecotone/composer.json

@@ -66,7 +66,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-main": "1.240.1-dev"
+            "dev-main": "1.241.0-dev"
         },
         "ecotone": {
             "repository": "ecotone"
@@ -87,7 +87,7 @@
                 "description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
             }
         },
-        "release-time": "2024-12-07 13:28:31"
+        "release-time": "2024-12-28 19:05:37"
     },
     "config": {
         "sort-packages": true,

packages/Ecotone/src/Lite/EcotoneLite.php

@@ -21,14 +21,9 @@
 use Ecotone\Messaging\Config\ServiceCacheConfiguration;
 use Ecotone\Messaging\Config\ServiceConfiguration;
 use Ecotone\Messaging\ConfigurationVariableService;
-use Ecotone\Messaging\Handler\ClassDefinition;
-use Ecotone\Messaging\Handler\TypeDescriptor;
 use Ecotone\Messaging\InMemoryConfigurationVariableService;
 use Ecotone\Messaging\Support\Assert;
-use Ecotone\Modelling\Attribute\Aggregate;
-use Ecotone\Modelling\Attribute\EventSourcingAggregate;
 use Ecotone\Modelling\BaseEventSourcingConfiguration;
-use Ecotone\Modelling\Config\RegisterAggregateRepositoryChannels;
 
 use function json_decode;
 

packages/Ecotone/src/Lite/Test/ConfiguredMessagingSystemWithTestSupport.php

@@ -15,7 +15,6 @@
 use Ecotone\Modelling\CommandBus;
 use Ecotone\Modelling\DistributedBus;
 use Ecotone\Modelling\EventBus;
-use Ecotone\Modelling\EventSourcingExecutor\GroupedEventSourcingExecutor;
 use Ecotone\Modelling\QueryBus;
 
 /**

packages/Ecotone/src/Lite/Test/FlowTestSupport.php

@@ -23,13 +23,11 @@
 use Ecotone\Modelling\AggregateFlow\SaveAggregate\AggregateResolver\AggregateDefinitionRegistry;
 use Ecotone\Modelling\AggregateMessage;
 use Ecotone\Modelling\CommandBus;
-use Ecotone\Modelling\Config\MessageBusChannel;
 use Ecotone\Modelling\Config\AggregrateHandlerModule;
+use Ecotone\Modelling\Config\MessageBusChannel;
 use Ecotone\Modelling\Event;
 use Ecotone\Modelling\EventBus;
-use Ecotone\Modelling\EventSourcingExecutor\GroupedEventSourcingExecutor;
 use Ecotone\Modelling\QueryBus;
-use Ecotone\Test\StubEventSourcedAggregate;
 
 /**
  * @template T

packages/Ecotone/src/Messaging/Config/ModuleClassList.php

@@ -46,10 +46,10 @@
 use Ecotone\Messaging\Handler\Logger\Config\LoggingModule;
 use Ecotone\Messaging\Handler\Logger\Config\MessageHandlerLogger;
 use Ecotone\Modelling\CommandBus;
-use Ecotone\Modelling\Config\MessageHandlerRoutingModule;
+use Ecotone\Modelling\Config\AggregrateHandlerModule;
 use Ecotone\Modelling\Config\DistributedGatewayModule;
 use Ecotone\Modelling\Config\InstantRetry\InstantRetryModule;
-use Ecotone\Modelling\Config\AggregrateHandlerModule;
+use Ecotone\Modelling\Config\MessageHandlerRoutingModule;
 use Ecotone\Modelling\Config\ServiceHandlerModule;
 use Ecotone\Modelling\EventBus;
 use Ecotone\Modelling\MessageHandling\MetadataPropagator\MessageHeadersPropagatorInterceptor;

packages/Ecotone/src/Messaging/Handler/Enricher/PropertyEditorAccessor.php

@@ -42,7 +42,7 @@ public static function getDefinition(): Definition
         return new Definition(
             self::class,
             [
-                Reference::to(ExpressionEvaluationService::REFERENCE)
+                Reference::to(ExpressionEvaluationService::REFERENCE),
             ],
             [self::class, 'create']
         );

packages/Ecotone/src/Messaging/Handler/Router/HeaderExistsRouter.php

@@ -17,7 +17,6 @@
  */
 final class HeaderExistsRouter implements RouteSelector, DefinedObject
 {
-
     private function __construct(private string $headerName, private string $routeToChannel, private string $fallbackRoute)
     {
     }
@@ -43,7 +42,7 @@ public function getDefinition(): Definition
         return new Definition(self::class, [
             $this->headerName,
             $this->routeToChannel,
-            $this->fallbackRoute
+            $this->fallbackRoute,
         ], 'create');
     }
 }

packages/Ecotone/src/Messaging/Handler/Transformer/TransformerBuilder.php

@@ -133,7 +133,7 @@ public function getParameterConverters(): array
 
     public function compile(MessagingContainerBuilder $builder): Definition
     {
-        list($objectToInvokeOn, $interfaceToCallReference, $interfaceToCall) = $this->prepare($builder);
+        [$objectToInvokeOn, $interfaceToCallReference, $interfaceToCall] = $this->prepare($builder);
 
         $newImplementation = MessageProcessorActivatorBuilder::create()
             ->withEndpointId($this->getEndpointId())
@@ -157,7 +157,7 @@ public function compile(MessagingContainerBuilder $builder): Definition
 
     public function compileProcessor(MessagingContainerBuilder $builder): Definition
     {
-        list($objectToInvokeOn, $interfaceToCallReference, $interfaceToCall) = $this->prepare($builder);
+        [$objectToInvokeOn, $interfaceToCallReference, $interfaceToCall] = $this->prepare($builder);
 
         return MethodInvokerBuilder::create(
             $objectToInvokeOn,
@@ -214,10 +214,10 @@ public function prepare(MessagingContainerBuilder $builder): array
 
         $interfaceToCall = $builder->getInterfaceToCall($interfaceToCallReference);
 
-        if (!$interfaceToCall->canReturnValue()) {
+        if (! $interfaceToCall->canReturnValue()) {
             throw InvalidArgumentException::create("Can't create transformer for {$interfaceToCall}, because method has no return value");
         }
 
-        return array($objectToInvokeOn, $interfaceToCallReference, $interfaceToCall);
+        return [$objectToInvokeOn, $interfaceToCallReference, $interfaceToCall];
     }
 }