@@ -167,6 +167,8 @@ public function releaseIncreasesNumberOfReleases()
167167 $ this ->queue ->release ($ messageId );
168168 $ message = $ this ->queue ->waitAndReserve (1 );
169169 $ this ->assertSame (2 , $ message ->getNumberOfReleases ());
170+
171+ $ this ->queue ->abort ($ messageId );
170172 }
171173
172174 /**
@@ -191,6 +193,17 @@ public function countReadyReturnsZeroByDefault()
191193 $ this ->assertSame (0 , $ this ->queue ->countReady ());
192194 }
193195
196+ /**
197+ * @test
198+ */
199+ public function countReadyReturnsNumberOfReadyJobs ()
200+ {
201+ $ this ->queue ->submit ('First message ' );
202+ $ this ->queue ->submit ('Second message ' );
203+
204+ $ this ->assertSame (2 , $ this ->queue ->countReady ());
205+ }
206+
194207 /**
195208 * @test
196209 */
@@ -199,6 +212,20 @@ public function countFailedReturnsZeroByDefault()
199212 $ this ->assertSame (0 , $ this ->queue ->countFailed ());
200213 }
201214
215+ /**
216+ * @test
217+ */
218+ public function countFailedReturnsNumberOfFailedMessages ()
219+ {
220+ $ messageId = $ this ->queue ->submit ('A message ' );
221+
222+ $ this ->queue ->waitAndReserve (1 );
223+ $ this ->assertSame (0 , $ this ->queue ->countFailed ());
224+
225+ $ this ->queue ->abort ($ messageId );
226+ $ this ->assertSame (1 , $ this ->queue ->countFailed ());
227+ }
228+
202229 /**
203230 * @test
204231 */
@@ -210,11 +237,14 @@ public function countReservedReturnsZeroByDefault()
210237 /**
211238 * @test
212239 */
213- public function countReturnsNumberOfReadyJobs ()
240+ public function countReservedReturnsNumberOfReservedMessages ()
214241 {
215- $ this ->queue ->submit ('First message ' );
216- $ this ->queue ->submit ('Second message ' );
242+ $ messageId = $ this ->queue ->submit ('A message ' );
217243
218- $ this ->assertSame (2 , $ this ->queue ->countReady ());
244+ $ this ->queue ->waitAndReserve (1 );
245+ $ this ->assertSame (1 , $ this ->queue ->countReserved ());
246+
247+ $ this ->queue ->abort ($ messageId );
248+ $ this ->assertSame (0 , $ this ->queue ->countReserved ());
219249 }
220250}
0 commit comments