Skip to content

Commit bd15171

Browse files
dgafkagithub-actions[bot]
dgafka
authored and
github-actions[bot]
committed
Release 1.243.0
1 parent 06a7f25 commit bd15171

File tree

19 files changed

+51
-59
lines changed

19 files changed

+51
-59
lines changed

‎packages/Amqp/composer.json‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242
},
4343
"require": {
4444
"ext-amqp": "*",
45-
"ecotone/enqueue": "~1.242.1",
45+
"ecotone/enqueue": "~1.243.0",
4646
"enqueue/amqp-ext": "^0.10.18",
4747
"enqueue/dsn": "^0.10.4",
4848
"enqueue/enqueue": "^0.10.0"
@@ -65,7 +65,7 @@
6565
},
6666
"extra": {
6767
"branch-alias": {
68-
"dev-main": "1.242.1-dev"
68+
"dev-main": "1.243.0-dev"
6969
},
7070
"ecotone": {
7171
"repository": "amqp"
@@ -86,7 +86,7 @@
8686
"description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
8787
}
8888
},
89-
"release-time": "2025-01-24 07:43:42"
89+
"release-time": "2025-01-26 21:10:48"
9090
},
9191
"config": {
9292
"allow-plugins": {

‎packages/Amqp/src/AmqpOutboundChannelAdapter.php‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,6 @@
44

55
namespace Ecotone\Amqp;
66

7-
use AMQPChannelException;
8-
use AMQPConnectionException;
97
use Ecotone\Amqp\Transaction\AmqpTransactionInterceptor;
108
use Ecotone\Enqueue\CachedConnectionFactory;
119
use Ecotone\Messaging\Channel\PollableChannel\Serialization\OutboundMessageConverter;
@@ -82,7 +80,7 @@ public function handle(Message $message): void
8280

8381
/** @var AmqpContext $context */
8482
$context = $this->connectionFactory->createContext();
85-
if ($this->publisherAcknowledgments && !$this->amqpTransactionInterceptor->isRunningInTransaction()) {
83+
if ($this->publisherAcknowledgments && ! $this->amqpTransactionInterceptor->isRunningInTransaction()) {
8684
/** Ensures no messages are lost along the way when heartbeat is lost and ensures messages was peristed on the Broker side. Without this message can be simply "swallowed" without throwing exception */
8785
$context->getExtChannel()->confirmSelect();
8886
}
@@ -94,7 +92,7 @@ public function handle(Message $message): void
9492
// this allow for having queue per delay instead of queue per delay + exchangeName
9593
->send(new AmqpTopic($exchangeName), $messageToSend);
9694

97-
if ($this->publisherAcknowledgments && !$this->amqpTransactionInterceptor->isRunningInTransaction()) {
95+
if ($this->publisherAcknowledgments && ! $this->amqpTransactionInterceptor->isRunningInTransaction()) {
9896
$context->getExtChannel()->waitForConfirm();
9997
}
10098
}

‎packages/Amqp/src/AmqpReconnectableConnectionFactory.php‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
use Interop\Queue\SubscriptionConsumer;
1515
use ReflectionClass;
1616
use ReflectionProperty;
17+
use RuntimeException;
1718

1819
/**
1920
* licence Apache-2.0
@@ -38,7 +39,7 @@ public function createContext(): Context
3839
}
3940

4041
$context = $this->connectionFactory->createContext();
41-
$context->getExtChannel()->setConfirmCallback(fn() => false, fn() => throw new \RuntimeException("Message was failed to be persisted in RabbitMQ instance. Check RabbitMQ server logs."));
42+
$context->getExtChannel()->setConfirmCallback(fn () => false, fn () => throw new RuntimeException('Message was failed to be persisted in RabbitMQ instance. Check RabbitMQ server logs.'));
4243

4344
return $context;
4445
}
@@ -66,7 +67,7 @@ public function isDisconnected(?Context $context): bool
6667

6768
Assert::isSubclassOf($context, AmqpContext::class, 'Context must be ' . AmqpContext::class);
6869

69-
if (!$context->getExtChannel()->getConnection()->isConnected()) {
70+
if (! $context->getExtChannel()->getConnection()->isConnected()) {
7071
return true;
7172
}
7273

‎packages/Amqp/src/Transaction/AmqpTransactionInterceptor.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ public function transactional(
9191
'AMQP transaction was roll backed',
9292
$message,
9393
[
94-
'exception' => $exception
94+
'exception' => $exception,
9595
]
9696
);
9797

‎packages/Amqp/tests/Configuration/AmqpModuleTest.php‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -12,15 +12,8 @@
1212
use Ecotone\Messaging\Config\ConfiguredMessagingSystem;
1313
use Ecotone\Messaging\Config\InMemoryModuleMessaging;
1414
use Ecotone\Messaging\Config\MessagingSystemConfiguration;
15-
use Ecotone\Messaging\Config\ServiceConfiguration;
16-
use Ecotone\Messaging\Conversion\ArrayToJson\ArrayToJsonConverterBuilder;
17-
use Ecotone\Messaging\Conversion\MediaType;
18-
use Ecotone\Messaging\Handler\InMemoryReferenceSearchService;
1915
use Ecotone\Messaging\Handler\InterfaceToCallRegistry;
2016
use Ecotone\Messaging\MessagingException;
21-
use Ecotone\Messaging\PollableChannel;
22-
use Ecotone\Messaging\Support\MessageBuilder;
23-
use Enqueue\AmqpExt\AmqpConnectionFactory;
2417
use Test\Ecotone\Amqp\AmqpMessagingTestCase;
2518

2619
/**

‎packages/Amqp/tests/Integration/GeneralAmqpTest.php‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public function test_messages_are_delivered_after_lost_heartbeat(): void
4848
$ecotone = $this->bootstrapEcotone(
4949
namespaces: ['Test\Ecotone\Amqp\Fixture\Order'],
5050
services: [new OrderService(), new OrderErrorHandler(),
51-
// 'logger' => new EchoLogger()
51+
// 'logger' => new EchoLogger()
5252
],
5353
amqpConfig: ['heartbeat' => 2]
5454
);

‎packages/Dbal/composer.json‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
}
3434
},
3535
"require": {
36-
"ecotone/enqueue": "~1.242.1",
36+
"ecotone/enqueue": "~1.243.0",
3737
"enqueue/dbal": "^0.10.17",
3838
"doctrine/dbal": "^2.12.0|^3.0"
3939
},
@@ -45,7 +45,7 @@
4545
"doctrine/cache": "^1.0.0|^2.0",
4646
"doctrine/annotations": "^1.13|^2.0",
4747
"wikimedia/composer-merge-plugin": "^2.1",
48-
"ecotone/jms-converter": "~1.242.1",
48+
"ecotone/jms-converter": "~1.243.0",
4949
"symfony/expression-language": "^6.0|^7.0"
5050
},
5151
"scripts": {
@@ -58,7 +58,7 @@
5858
},
5959
"extra": {
6060
"branch-alias": {
61-
"dev-main": "1.242.1-dev"
61+
"dev-main": "1.243.0-dev"
6262
},
6363
"ecotone": {
6464
"repository": "dbal"
@@ -79,7 +79,7 @@
7979
"description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
8080
}
8181
},
82-
"release-time": "2025-01-24 07:43:42"
82+
"release-time": "2025-01-26 21:10:48"
8383
},
8484
"config": {
8585
"allow-plugins": {

‎packages/Ecotone/composer.json‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@
6666
},
6767
"extra": {
6868
"branch-alias": {
69-
"dev-main": "1.242.1-dev"
69+
"dev-main": "1.243.0-dev"
7070
},
7171
"ecotone": {
7272
"repository": "ecotone"
@@ -87,7 +87,7 @@
8787
"description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
8888
}
8989
},
90-
"release-time": "2025-01-24 07:43:42"
90+
"release-time": "2025-01-26 21:10:48"
9191
},
9292
"config": {
9393
"sort-packages": true,

‎packages/Enqueue/composer.json‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
}
3434
},
3535
"require": {
36-
"ecotone/ecotone": "~1.242.1",
36+
"ecotone/ecotone": "~1.243.0",
3737
"queue-interop/queue-interop": "^0.8",
3838
"enqueue/dsn": "^0.10.4"
3939
},
@@ -56,7 +56,7 @@
5656
},
5757
"extra": {
5858
"branch-alias": {
59-
"dev-main": "1.242.1-dev"
59+
"dev-main": "1.243.0-dev"
6060
},
6161
"ecotone": {
6262
"repository": "enqueue"
@@ -77,7 +77,7 @@
7777
"description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
7878
}
7979
},
80-
"release-time": "2025-01-24 07:43:42"
80+
"release-time": "2025-01-26 21:10:48"
8181
},
8282
"config": {
8383
"allow-plugins": {

‎packages/JmsConverter/composer.json‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838
}
3939
},
4040
"require": {
41-
"ecotone/ecotone": "~1.242.1",
41+
"ecotone/ecotone": "~1.243.0",
4242
"jms/serializer": "^3.17",
4343
"symfony/cache": "^5.4|^6.1|^7.0"
4444
},
@@ -60,7 +60,7 @@
6060
},
6161
"extra": {
6262
"branch-alias": {
63-
"dev-main": "1.242.1-dev"
63+
"dev-main": "1.243.0-dev"
6464
},
6565
"ecotone": {
6666
"repository": "jms-converter"
@@ -81,7 +81,7 @@
8181
"description": "Allows to use Enterprise features of Ecotone. For more information please write to [email protected]"
8282
}
8383
},
84-
"release-time": "2025-01-24 07:43:42"
84+
"release-time": "2025-01-26 21:10:48"
8585
},
8686
"config": {
8787
"sort-packages": true,

0 commit comments

Comments
 (0)