Release 1.230.0

ecotoneframework · Aug 31, 2024 · f91e310 · f91e310
1 parent bc5780d
commit f91e310
Show file tree

Hide file tree

Showing 53 changed files with 127 additions and 174 deletions.
diff --git a/packages/Amqp/composer.json b/packages/Amqp/composer.json
@@ -42,7 +42,7 @@
     },
     "require": {
         "ext-amqp": "*",
-        "ecotone/enqueue": "~1.229.1",
+        "ecotone/enqueue": "~1.230.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.229.1-dev"
+            "dev-main": "1.230.0-dev"
         },
         "ecotone": {
             "repository": "amqp"

diff --git a/packages/Amqp/src/AmqpInboundChannelAdapter.php b/packages/Amqp/src/AmqpInboundChannelAdapter.php
@@ -7,7 +7,6 @@
 use AMQPChannelException;
 use AMQPConnectionException;
 use Ecotone\Enqueue\CachedConnectionFactory;
-use Ecotone\Enqueue\EnqueueHeader;
 use Ecotone\Enqueue\EnqueueInboundChannelAdapter;
 use Ecotone\Enqueue\InboundMessageConverter;
 use Ecotone\Messaging\Channel\QueueChannel;

diff --git a/packages/Amqp/src/Transaction/AmqpTransactionModule.php b/packages/Amqp/src/Transaction/AmqpTransactionModule.php
@@ -5,7 +5,6 @@
 use function array_map;
 
 use Ecotone\Amqp\Configuration\AmqpConfiguration;
-
 use Ecotone\AnnotationFinder\AnnotationFinder;
 use Ecotone\Messaging\Attribute\AsynchronousRunningEndpoint;
 use Ecotone\Messaging\Attribute\ConsoleCommand;

diff --git a/packages/Amqp/tests/Integration/DistributedCommandBusTest.php b/packages/Amqp/tests/Integration/DistributedCommandBusTest.php
@@ -31,7 +31,7 @@ public function test_distributing_command_to_another_service(): void
     {
         $userService = $this->bootstrapEcotone('user_service', ['Test\Ecotone\Amqp\Fixture\DistributedCommandBus\Publisher'], [new UserService()]);
         $ticketService = $this->bootstrapEcotone('ticket_service', ['Test\Ecotone\Amqp\Fixture\DistributedCommandBus\Receiver'], [new TicketServiceReceiver(),
-//            'logger' => new EchoLogger(),
+            //            'logger' => new EchoLogger(),
         ]);
 
         $ticketService->run('ticket_service', ExecutionPollingMetadata::createWithTestingSetup(maxExecutionTimeInMilliseconds: 500));
@@ -48,7 +48,7 @@ public function test_distributing_command_misses_heartbeat_and_reconnects(): voi
         $executionPollingMetadata = ExecutionPollingMetadata::createWithDefaults()->withExecutionTimeLimitInMilliseconds(10000)->withStopOnError(false);
         $userService = $this->bootstrapEcotone('user_service', ['Test\Ecotone\Amqp\Fixture\DistributedCommandBus\Publisher'], [new UserService()], amqpConfig: ['heartbeat' => 1]);
         $ticketService = $this->bootstrapEcotone('ticket_service', ['Test\Ecotone\Amqp\Fixture\DistributedCommandBus\Receiver', 'Test\Ecotone\Amqp\Fixture\DistributedCommandBus\ReceiverEventHandler'], [new TicketServiceReceiver([0, 6, 0]), new TicketNotificationEventHandler([0, 6, 0]),
-//            'logger' => new EchoLogger(),
+            //            'logger' => new EchoLogger(),
         ], amqpConfig: ['heartbeat' => 1]);
 
         $ticketService->run('ticket_service', $executionPollingMetadata);

diff --git a/packages/Dbal/composer.json b/packages/Dbal/composer.json
@@ -33,7 +33,7 @@
         }
     },
     "require": {
-        "ecotone/enqueue": "~1.229.1",
+        "ecotone/enqueue": "~1.230.0",
         "enqueue/dbal": "^0.10.17",
         "doctrine/dbal": "^2.12.0|^3.0"
     },
@@ -45,7 +45,7 @@
         "doctrine/cache": "^1.0.0",
         "doctrine/annotations": "^1.13",
         "wikimedia/composer-merge-plugin": "^2.1",
-        "ecotone/jms-converter": "~1.229.1",
+        "ecotone/jms-converter": "~1.230.0",
         "symfony/expression-language": "^6.0|^7.0"
     },
     "scripts": {
@@ -58,7 +58,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-main": "1.229.1-dev"
+            "dev-main": "1.230.0-dev"
         },
         "ecotone": {
             "repository": "dbal"

diff --git a/packages/Dbal/src/DbalTransaction/DbalTransactionInterceptor.php b/packages/Dbal/src/DbalTransaction/DbalTransactionInterceptor.php
@@ -77,7 +77,7 @@ public function transactional(MethodInvocation $methodInvocation, Message $messa
             $retryStrategy->runCallbackWithRetries(function () use ($connection) {
                 try {
                     $connection->beginTransaction();
-                }catch (\Exception $exception) {
+                } catch (Exception $exception) {
                     $connection->close();
                     throw $exception;
                 }
@@ -102,7 +102,8 @@ public function transactional(MethodInvocation $methodInvocation, Message $messa
 
                         try {
                             $connection->rollBack();
-                        } catch (Exception) {};
+                        } catch (Exception) {
+                        };
 
                         continue;
                     }

diff --git a/packages/Dbal/src/Recoverability/DbalDeadLetterHandler.php b/packages/Dbal/src/Recoverability/DbalDeadLetterHandler.php
@@ -6,7 +6,6 @@
 
 use DateTime;
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Exception\ConnectionException;
 use Doctrine\DBAL\Exception\UniqueConstraintViolationException;
 use Doctrine\DBAL\Schema\Table;
 use Doctrine\DBAL\Types\Types;
@@ -202,7 +201,7 @@ public function store(Message $message): void
         $retryStrategy->runCallbackWithRetries(function () use ($message) {
             try {
                 $this->insertHandledMessage($message->getPayload(), $message->getHeaders()->headers());
-            }catch (\Exception $exception) {
+            } catch (\Exception $exception) {
                 $this->getConnection()->close();
 
                 throw $exception;

diff --git a/packages/Dbal/tests/DbalMessagingTestCase.php b/packages/Dbal/tests/DbalMessagingTestCase.php
@@ -55,8 +55,7 @@ public static function prepareFailingConnection(
         array $connectionFailuresOnCommit = [],
         array $connectionFailureOnStoreInDeadLetter = [],
         array $connectionFailureOnMessageAcknowledge = [],
-    ): ConnectionFactory
-    {
+    ): ConnectionFactory {
         return ManagerRegistryEmulator::create((
                 new FailingConnection(
                     self::prepareConnection()->createContext()->getDbalConnection(),

diff --git a/packages/Dbal/tests/Fixture/Betting/BetNotificator.php b/packages/Dbal/tests/Fixture/Betting/BetNotificator.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace  Test\Ecotone\Dbal\Fixture\Betting;
+namespace Test\Ecotone\Dbal\Fixture\Betting;
 
 use Ecotone\Messaging\Attribute\Asynchronous;
 use Ecotone\Modelling\Attribute\EventHandler;

diff --git a/packages/Dbal/tests/Fixture/Betting/BetPlaced.php b/packages/Dbal/tests/Fixture/Betting/BetPlaced.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace  Test\Ecotone\Dbal\Fixture\Betting;
+namespace Test\Ecotone\Dbal\Fixture\Betting;
 
 /**
  * licence Apache-2.0

diff --git a/packages/Dbal/tests/Fixture/Betting/BetService.php b/packages/Dbal/tests/Fixture/Betting/BetService.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace  Test\Ecotone\Dbal\Fixture\Betting;
+namespace Test\Ecotone\Dbal\Fixture\Betting;
 
 use Ecotone\Messaging\Attribute\Asynchronous;
 use Ecotone\Messaging\Attribute\Parameter\Header;

diff --git a/packages/Dbal/tests/Fixture/Betting/BetStatistics.php b/packages/Dbal/tests/Fixture/Betting/BetStatistics.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace  Test\Ecotone\Dbal\Fixture\Betting;
+namespace Test\Ecotone\Dbal\Fixture\Betting;
 
 use Ecotone\Messaging\Attribute\Asynchronous;
 use Ecotone\Modelling\Attribute\EventHandler;

diff --git a/packages/Dbal/tests/Fixture/Betting/BetWon.php b/packages/Dbal/tests/Fixture/Betting/BetWon.php
@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace  Test\Ecotone\Dbal\Fixture\Betting;
+namespace Test\Ecotone\Dbal\Fixture\Betting;
 
 /**
  * licence Apache-2.0