Skip to content

Commit 1ec1e8f

Browse files
committed
Add reset message queues before scenario
1 parent 3be5013 commit 1ec1e8f

File tree

2 files changed

+12
-3
lines changed

2 files changed

+12
-3
lines changed

src/Context/MessengerContext.php

+11-2
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,11 @@ public function allTransportMessagesShouldBeJson(string $transportName, PyString
110110
$actualMessageList[] = $this->convertToArray($envelope->getMessage());
111111
}
112112

113-
if (!$this->isMessagesAreSimilar($expectedMessageList, $actualMessageList)) {
113+
if (!$this->isMessagesAreSimilar(
114+
expected: $expectedMessageList,
115+
actual: $actualMessageList,
116+
multipleActual: true,
117+
)) {
114118
throw new Exception(
115119
sprintf(
116120
'The expected transport messages doesn\'t match actual: %s',
@@ -137,7 +141,12 @@ public function allTransportMessagesShouldBeJsonWithVariableFields(
137141
$actualMessageList[] = $this->convertToArray($envelope->getMessage());
138142
}
139143

140-
if (!$this->isMessagesAreSimilar($expectedMessageList, $actualMessageList, $variableFields, true)) {
144+
if (!$this->isMessagesAreSimilar(
145+
expected: $expectedMessageList,
146+
actual: $actualMessageList,
147+
requiredFields: $variableFields,
148+
multipleActual: true,
149+
)) {
141150
throw new Exception(
142151
sprintf(
143152
'The expected transport messages doesn\'t match actual: %s',

tests/MessengerContextTest.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,7 @@ public function testAllTransportMessagesShouldBeJson(): void
332332
->with($message)
333333
->willReturn(['key' => 'value']);
334334

335-
$expectedJson = new PyStringNode(['[{"key": "value"}]'], 1);
335+
$expectedJson = new PyStringNode(['{"key": "value"}'], 1);
336336

337337
$this->messengerContext->allTransportMessagesShouldBeJson('test', $expectedJson);
338338
}

0 commit comments

Comments
 (0)