3
3
namespace OldSound \RabbitMqBundle \Tests \RabbitMq ;
4
4
5
5
use OldSound \RabbitMqBundle \RabbitMq \RpcClient ;
6
+ use PhpAmqpLib \Message \AMQPMessage ;
6
7
7
8
class RpcClientTest extends \PHPUnit_Framework_TestCase
8
9
{
@@ -13,16 +14,22 @@ public function testProcessMessageWithCustomUnserializer()
13
14
->setMethods (array ('sendReply ' , 'maybeStopConsumer ' ))
14
15
->disableOriginalConstructor ()
15
16
->getMock ();
16
- $ message = $ this ->getMockBuilder ('\PhpAmqpLib\Message\AMQPMessage ' )->setMethods (array ('get ' ))->setConstructorArgs (array ('message ' ))->getMock ();
17
- $ serializer = $ this ->getMockBuilder ('\Symfony\Component\Serializer\SerializerInterface ' )->setMethods (array ('serialize ' , 'deserialize ' ))->getMock ();
17
+ /** @var AMQPMessage $message */
18
+ $ message = $ this ->getMockBuilder ('\PhpAmqpLib\Message\AMQPMessage ' )
19
+ ->setMethods (array ('get ' ))
20
+ ->setConstructorArgs (array ('message ' ))
21
+ ->getMock ();
22
+ $ serializer = $ this ->getMockBuilder ('\Symfony\Component\Serializer\SerializerInterface ' )
23
+ ->setMethods (array ('serialize ' , 'deserialize ' ))
24
+ ->getMock ();
18
25
$ serializer ->expects ($ this ->once ())->method ('deserialize ' )->with ('message ' , 'json ' , null );
19
26
$ client ->initClient (true );
20
27
$ client ->setUnserializer (function ($ data ) use ($ serializer ) {
21
28
$ serializer ->deserialize ($ data , 'json ' , null );
22
29
});
23
30
$ client ->processMessage ($ message );
24
31
}
25
-
32
+
26
33
public function testProcessMessageWithNotifyMethod ()
27
34
{
28
35
/** @var RpcClient $client */
@@ -31,7 +38,11 @@ public function testProcessMessageWithNotifyMethod()
31
38
->disableOriginalConstructor ()
32
39
->getMock ();
33
40
$ expectedNotify = 'message ' ;
34
- $ message = $ this ->getMock ('\PhpAmqpLib\Message\AMQPMessage ' , array ('get ' ), array ($ expectedNotify ));
41
+ /** @var AMQPMessage $message */
42
+ $ message = $ this ->getMockBuilder ('\PhpAmqpLib\Message\AMQPMessage ' )
43
+ ->setMethods (array ('get ' ))
44
+ ->setConstructorArgs (array ($ expectedNotify ))
45
+ ->getMock ();
35
46
$ notified = false ;
36
47
$ client ->notify (function ($ message ) use (&$ notified ) {
37
48
$ notified = $ message ;
0 commit comments