@@ -158,7 +158,7 @@ public function testConsumerReceiveMessageFromTopicDirectly()
158158 $ this ->amqpContext ->declareTopic ($ topic );
159159
160160 $ consumer = $ this ->amqpContext ->createConsumer ($ topic );
161- //guard
161+ // guard
162162 $ this ->assertNull ($ consumer ->receive (1000 ));
163163
164164 $ message = $ this ->amqpContext ->createMessage (__METHOD__ );
@@ -168,9 +168,9 @@ public function testConsumerReceiveMessageFromTopicDirectly()
168168 $ actualMessage = $ consumer ->receive (1000 );
169169
170170 $ this ->assertInstanceOf (AmqpMessage::class, $ actualMessage );
171- $ consumer ->acknowledge ($ message );
171+ $ consumer ->acknowledge ($ actualMessage );
172172
173- $ this ->assertEquals (__METHOD__ , $ message ->getBody ());
173+ $ this ->assertEquals (__METHOD__ , $ actualMessage ->getBody ());
174174 }
175175
176176 public function testConsumerReceiveMessageWithZeroTimeout ()
@@ -181,7 +181,7 @@ public function testConsumerReceiveMessageWithZeroTimeout()
181181 $ this ->amqpContext ->declareTopic ($ topic );
182182
183183 $ consumer = $ this ->amqpContext ->createConsumer ($ topic );
184- //guard
184+ // guard
185185 $ this ->assertNull ($ consumer ->receive (1000 ));
186186
187187 $ message = $ this ->amqpContext ->createMessage (__METHOD__ );
@@ -192,9 +192,9 @@ public function testConsumerReceiveMessageWithZeroTimeout()
192192 $ actualMessage = $ consumer ->receive (0 );
193193
194194 $ this ->assertInstanceOf (AmqpMessage::class, $ actualMessage );
195- $ consumer ->acknowledge ($ message );
195+ $ consumer ->acknowledge ($ actualMessage );
196196
197- $ this ->assertEquals (__METHOD__ , $ message ->getBody ());
197+ $ this ->assertEquals (__METHOD__ , $ actualMessage ->getBody ());
198198 }
199199
200200 public function testPurgeMessagesFromQueue ()
0 commit comments