@@ -61,9 +61,9 @@ public function testShouldPublishMessageToTopic()
61
61
->expects ($ this ->once ())
62
62
->method ('basic_publish ' )
63
63
->with ($ this ->isInstanceOf (LibAMQPMessage::class), 'topic ' , 'routing-key ' )
64
- ->will ( $ this -> returnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
64
+ ->willReturnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
65
65
$ amqpMessage = $ message ;
66
- }))
66
+ })
67
67
;
68
68
69
69
$ topic = new AmqpTopic ('topic ' );
@@ -86,9 +86,9 @@ public function testShouldPublishMessageToQueue()
86
86
->expects ($ this ->once ())
87
87
->method ('basic_publish ' )
88
88
->with ($ this ->isInstanceOf (LibAMQPMessage::class), $ this ->isEmpty (), 'queue ' )
89
- ->will ( $ this -> returnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
89
+ ->willReturnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
90
90
$ amqpMessage = $ message ;
91
- }))
91
+ })
92
92
;
93
93
94
94
$ queue = new AmqpQueue ('queue ' );
@@ -107,9 +107,9 @@ public function testShouldSetMessageHeaders()
107
107
$ channel
108
108
->expects ($ this ->once ())
109
109
->method ('basic_publish ' )
110
- ->will ( $ this -> returnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
110
+ ->willReturnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
111
111
$ amqpMessage = $ message ;
112
- }))
112
+ })
113
113
;
114
114
115
115
$ producer = new AmqpProducer ($ channel , $ this ->createContextMock ());
@@ -126,9 +126,9 @@ public function testShouldSetMessageProperties()
126
126
$ channel
127
127
->expects ($ this ->once ())
128
128
->method ('basic_publish ' )
129
- ->will ( $ this -> returnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
129
+ ->willReturnCallback (function (LibAMQPMessage $ message ) use (&$ amqpMessage ) {
130
130
$ amqpMessage = $ message ;
131
- }))
131
+ })
132
132
;
133
133
134
134
$ producer = new AmqpProducer ($ channel , $ this ->createContextMock ());
0 commit comments