@@ -158,7 +158,7 @@ public function testConsumerReceiveMessageFromTopicDirectly()
158
158
$ this ->amqpContext ->declareTopic ($ topic );
159
159
160
160
$ consumer = $ this ->amqpContext ->createConsumer ($ topic );
161
- //guard
161
+ // guard
162
162
$ this ->assertNull ($ consumer ->receive (1000 ));
163
163
164
164
$ message = $ this ->amqpContext ->createMessage (__METHOD__ );
@@ -168,9 +168,9 @@ public function testConsumerReceiveMessageFromTopicDirectly()
168
168
$ actualMessage = $ consumer ->receive (1000 );
169
169
170
170
$ this ->assertInstanceOf (AmqpMessage::class, $ actualMessage );
171
- $ consumer ->acknowledge ($ message );
171
+ $ consumer ->acknowledge ($ actualMessage );
172
172
173
- $ this ->assertEquals (__METHOD__ , $ message ->getBody ());
173
+ $ this ->assertEquals (__METHOD__ , $ actualMessage ->getBody ());
174
174
}
175
175
176
176
public function testConsumerReceiveMessageWithZeroTimeout ()
@@ -181,7 +181,7 @@ public function testConsumerReceiveMessageWithZeroTimeout()
181
181
$ this ->amqpContext ->declareTopic ($ topic );
182
182
183
183
$ consumer = $ this ->amqpContext ->createConsumer ($ topic );
184
- //guard
184
+ // guard
185
185
$ this ->assertNull ($ consumer ->receive (1000 ));
186
186
187
187
$ message = $ this ->amqpContext ->createMessage (__METHOD__ );
@@ -192,9 +192,9 @@ public function testConsumerReceiveMessageWithZeroTimeout()
192
192
$ actualMessage = $ consumer ->receive (0 );
193
193
194
194
$ this ->assertInstanceOf (AmqpMessage::class, $ actualMessage );
195
- $ consumer ->acknowledge ($ message );
195
+ $ consumer ->acknowledge ($ actualMessage );
196
196
197
- $ this ->assertEquals (__METHOD__ , $ message ->getBody ());
197
+ $ this ->assertEquals (__METHOD__ , $ actualMessage ->getBody ());
198
198
}
199
199
200
200
public function testPurgeMessagesFromQueue ()
0 commit comments