We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 205c877 commit 3d0250cCopy full SHA for 3d0250c
pkg/enqueue/Tests/Functional/Client/RpcClientTest.php
@@ -79,7 +79,7 @@ public function testProduceAndConsumeOneMessage()
79
$this->assertInstanceOf(PsrMessage::class, $requestMessage);
80
$this->assertEquals('Hi Thomas!', $requestMessage->getBody());
81
82
- $replyMessage = $promise->getMessage();
+ $replyMessage = $promise->receive();
83
$this->assertEquals('Hi John!', $replyMessage->getBody());
84
}
85
pkg/enqueue/Tests/Rpc/PromiseTest.php
@@ -89,7 +89,7 @@ public function testOnReceiveShouldCallFinallyCallbackEvenIfExceptionThrown()
89
90
public function testOnReceiveShouldThrowExceptionIfCallbackReturnNotMessageInstance()
91
{
92
- $receivecb = function() use (&$invokedReceive) {
+ $receivecb = function() {
93
return new \stdClass();
94
};
95
0 commit comments