Skip to content

Commit 5c469c6

Browse files
committed
Renamed named constructor of DbalMessage
1 parent 811c2be commit 5c469c6

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

pkg/dbal/DbalConsumer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ protected function receiveMessage(): ?DbalMessage
142142
$this->dbal->commit();
143143

144144
if (empty($dbalMessage['time_to_live']) || ($dbalMessage['time_to_live'] / 1000) > microtime(true)) {
145-
return DbalMessage::fromArray($dbalMessage);
145+
return DbalMessage::fromArrayDbResult($dbalMessage);
146146
}
147147

148148
return null;

pkg/dbal/DbalMessage.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public function __construct(string $body = '', array $properties = [], array $he
6767
$this->deliveryDelay = null;
6868
}
6969

70-
public static function fromArray(array $dbalMessage): self
70+
public static function fromArrayDbResult(array $dbalMessage): self
7171
{
7272
$dbalMessageObj = new self(
7373
$dbalMessage['body'],

pkg/dbal/DbalSubscriptionConsumer.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public function consume(int $timeout = 0): void
6262
if ($message) {
6363
$this->dbal->delete($this->context->getTableName(), ['id' => $message['id']], ['id' => Type::GUID]);
6464

65-
$dbalMessage = DbalMessage::fromArray($message);
65+
$dbalMessage = DbalMessage::fromArrayDbResult($message);
6666

6767
/**
6868
* @var DbalConsumer

pkg/dbal/Tests/DbalMessageTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public function testCouldBeCreatedFromArray()
3636
'properties' => json_encode(['barProp' => 'barPropVal']),
3737
'headers' => json_encode(['fooHeader' => 'fooHeaderVal']),
3838
];
39-
$message = DbalMessage::fromArray($arrayData);
39+
$message = DbalMessage::fromArrayDbResult($arrayData);
4040

4141
$this->assertSame('theBody', $message->getBody());
4242
$this->assertSame(['barProp' => 'barPropVal'], $message->getProperties());

0 commit comments

Comments
 (0)