Skip to content

Commit 217544d

Browse files
committed
Fix compat
1 parent 667fe84 commit 217544d

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

pkg/async-event-dispatcher/DependencyInjection/AsyncTransformersPass.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77

88
class AsyncTransformersPass implements CompilerPassInterface
99
{
10-
public function process(ContainerBuilder $container)
10+
public function process(ContainerBuilder $container): void
1111
{
1212
if (false == $container->hasDefinition('enqueue.events.registry')) {
1313
return;

pkg/dbal/DbalConsumerHelperTrait.php

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -53,22 +53,22 @@ protected function fetchMessage(array $queues, int $redeliveryDelay): ?DbalMessa
5353

5454
while (microtime(true) < $endAt) {
5555
try {
56-
$result = $select->execute()->fetchAssociative();
56+
$result = $select->executeQuery()->fetchAssociative();
5757
if (empty($result)) {
5858
return null;
5959
}
6060

6161
$update
6262
->setParameter('messageId', $result['id'], DbalType::GUID);
6363

64-
if ($update->execute()) {
64+
if ($update->executeQuery()) {
6565
$deliveredMessage = $this->getConnection()->createQueryBuilder()
6666
->select('*')
6767
->from($this->getContext()->getTableName())
6868
->andWhere('delivery_id = :deliveryId')
6969
->setParameter('deliveryId', $deliveryId, DbalType::GUID)
7070
->setMaxResults(1)
71-
->execute()
71+
->executeQuery()
7272
->fetchAssociative();
7373

7474
// the message has been removed by a 3rd party, such as truncate operation.
@@ -108,7 +108,7 @@ protected function redeliverMessages(): void
108108
;
109109

110110
try {
111-
$update->execute();
111+
$update->executeQuery();
112112

113113
$this->redeliverMessagesLastExecutedAt = microtime(true);
114114
} catch (RetryableException $e) {
@@ -135,7 +135,7 @@ protected function removeExpiredMessages(): void
135135
;
136136

137137
try {
138-
$delete->execute();
138+
$delete->executeQuery();
139139
} catch (RetryableException $e) {
140140
// maybe next time we'll get more luck
141141
}

0 commit comments

Comments
 (0)