@@ -33,7 +33,7 @@ abstract class AbstractQueueTest extends FunctionalTestCase
3333 /**
3434 * Set up dependencies
3535 */
36- public function setUp ()
36+ public function setUp (): void
3737 {
3838 parent ::setUp ();
3939 $ configurationManager = $ this ->objectManager ->get (ConfigurationManager::class);
@@ -65,7 +65,7 @@ abstract protected function getQueue();
6565 public function submitReturnsMessageId ()
6666 {
6767 $ messageId = $ this ->queue ->submit ('some message payload ' );
68- $ this -> assertInternalType ('string ' , $ messageId );
68+ self :: assertInternalType ('string ' , $ messageId );
6969 }
7070
7171 /**
@@ -77,16 +77,16 @@ public function submitAndWaitWithMessageWorks()
7777 $ this ->queue ->submit ($ payload );
7878
7979 $ message = $ this ->queue ->waitAndTake (1 );
80- $ this -> assertInstanceOf (Message::class, $ message , 'waitAndTake should return message ' );
81- $ this -> assertEquals ($ payload , $ message ->getPayload (), 'message should have payload as before ' );
80+ self :: assertInstanceOf (Message::class, $ message , 'waitAndTake should return message ' );
81+ self :: assertEquals ($ payload , $ message ->getPayload (), 'message should have payload as before ' );
8282 }
8383
8484 /**
8585 * @test
8686 */
8787 public function waitForMessageTimesOut ()
8888 {
89- $ this -> assertNull ($ this ->queue ->waitAndTake (1 ), 'wait should return NULL after timeout ' );
89+ self :: assertNull ($ this ->queue ->waitAndTake (1 ), 'wait should return NULL after timeout ' );
9090 }
9191
9292 /**
@@ -98,24 +98,24 @@ public function peekReturnsNextMessagesIfQueueHasMessages()
9898 $ this ->queue ->submit ('Another message ' );
9999
100100 $ messages = $ this ->queue ->peek (1 );
101- $ this -> assertCount (1 , $ messages , 'peek should return a message ' );
101+ self :: assertCount (1 , $ messages , 'peek should return a message ' );
102102 /** @var Message $firstMessage */
103103 $ firstMessage = array_shift ($ messages );
104- $ this -> assertEquals ('First message ' , $ firstMessage ->getPayload ());
104+ self :: assertEquals ('First message ' , $ firstMessage ->getPayload ());
105105
106106 $ messages = $ this ->queue ->peek (1 );
107- $ this -> assertCount (1 , $ messages , 'peek should return a message again ' );
107+ self :: assertCount (1 , $ messages , 'peek should return a message again ' );
108108 /** @var Message $firstMessage */
109109 $ firstMessage = array_shift ($ messages );
110- $ this -> assertEquals ('First message ' , $ firstMessage ->getPayload (), 'second peek should return the same message again ' );
110+ self :: assertEquals ('First message ' , $ firstMessage ->getPayload (), 'second peek should return the same message again ' );
111111 }
112112
113113 /**
114114 * @test
115115 */
116116 public function peekReturnsEmptyArrayIfQueueHasNoMessage ()
117117 {
118- $ this -> assertEquals ([], $ this ->queue ->peek (), 'peek should not return a message ' );
118+ self :: assertEquals ([], $ this ->queue ->peek (), 'peek should not return a message ' );
119119 }
120120
121121 /**
@@ -127,13 +127,13 @@ public function waitAndReserveWithFinishRemovesMessage()
127127 $ messageId = $ this ->queue ->submit ($ payload );
128128
129129 $ message = $ this ->queue ->waitAndReserve (1 );
130- $ this -> assertNotNull ($ message , 'waitAndReserve should receive message ' );
131- $ this -> assertSame ($ payload , $ message ->getPayload (), 'message should have payload as before ' );
130+ self :: assertNotNull ($ message , 'waitAndReserve should receive message ' );
131+ self :: assertSame ($ payload , $ message ->getPayload (), 'message should have payload as before ' );
132132
133133 $ message = $ this ->queue ->peek ();
134- $ this -> assertEquals ([], $ message , 'no message should be present in queue ' );
134+ self :: assertEquals ([], $ message , 'no message should be present in queue ' );
135135
136- $ this -> assertTrue ($ this ->queue ->finish ($ messageId ));
136+ self :: assertTrue ($ this ->queue ->finish ($ messageId ));
137137 }
138138
139139 /**
@@ -144,10 +144,10 @@ public function releasePutsMessageBackToQueue()
144144 $ messageId = $ this ->queue ->submit ('A message ' );
145145
146146 $ this ->queue ->waitAndReserve (1 );
147- $ this -> assertSame (0 , $ this ->queue ->countReady ());
147+ self :: assertSame (0 , $ this ->queue ->countReady ());
148148
149149 $ this ->queue ->release ($ messageId );
150- $ this -> assertSame (1 , $ this ->queue ->countReady ());
150+ self :: assertSame (1 , $ this ->queue ->countReady ());
151151 }
152152
153153 /**
@@ -158,15 +158,15 @@ public function releaseIncreasesNumberOfReleases()
158158 $ messageId = $ this ->queue ->submit ('A message ' );
159159
160160 $ message = $ this ->queue ->waitAndReserve (1 );
161- $ this -> assertSame (0 , $ message ->getNumberOfReleases ());
161+ self :: assertSame (0 , $ message ->getNumberOfReleases ());
162162
163163 $ this ->queue ->release ($ messageId );
164164 $ message = $ this ->queue ->waitAndReserve (1 );
165- $ this -> assertSame (1 , $ message ->getNumberOfReleases ());
165+ self :: assertSame (1 , $ message ->getNumberOfReleases ());
166166
167167 $ this ->queue ->release ($ messageId );
168168 $ message = $ this ->queue ->waitAndReserve (1 );
169- $ this -> assertSame (2 , $ message ->getNumberOfReleases ());
169+ self :: assertSame (2 , $ message ->getNumberOfReleases ());
170170
171171 $ this ->queue ->abort ($ messageId );
172172 }
@@ -181,16 +181,16 @@ public function abortRemovesMessageFromActiveQueue()
181181 $ this ->queue ->waitAndReserve (1 );
182182
183183 $ this ->queue ->abort ($ messageId );
184- $ this -> assertSame (0 , $ this ->queue ->countReady ());
185- $ this -> assertNull ($ this ->queue ->waitAndTake (1 ));
184+ self :: assertSame (0 , $ this ->queue ->countReady ());
185+ self :: assertNull ($ this ->queue ->waitAndTake (1 ));
186186 }
187187
188188 /**
189189 * @test
190190 */
191191 public function countReadyReturnsZeroByDefault ()
192192 {
193- $ this -> assertSame (0 , $ this ->queue ->countReady ());
193+ self :: assertSame (0 , $ this ->queue ->countReady ());
194194 }
195195
196196 /**
@@ -201,15 +201,15 @@ public function countReadyReturnsNumberOfReadyJobs()
201201 $ this ->queue ->submit ('First message ' );
202202 $ this ->queue ->submit ('Second message ' );
203203
204- $ this -> assertSame (2 , $ this ->queue ->countReady ());
204+ self :: assertSame (2 , $ this ->queue ->countReady ());
205205 }
206206
207207 /**
208208 * @test
209209 */
210210 public function countFailedReturnsZeroByDefault ()
211211 {
212- $ this -> assertSame (0 , $ this ->queue ->countFailed ());
212+ self :: assertSame (0 , $ this ->queue ->countFailed ());
213213 }
214214
215215 /**
@@ -220,18 +220,18 @@ public function countFailedReturnsNumberOfFailedMessages()
220220 $ messageId = $ this ->queue ->submit ('A message ' );
221221
222222 $ this ->queue ->waitAndReserve (1 );
223- $ this -> assertSame (0 , $ this ->queue ->countFailed ());
223+ self :: assertSame (0 , $ this ->queue ->countFailed ());
224224
225225 $ this ->queue ->abort ($ messageId );
226- $ this -> assertSame (1 , $ this ->queue ->countFailed ());
226+ self :: assertSame (1 , $ this ->queue ->countFailed ());
227227 }
228228
229229 /**
230230 * @test
231231 */
232232 public function countReservedReturnsZeroByDefault ()
233233 {
234- $ this -> assertSame (0 , $ this ->queue ->countReserved ());
234+ self :: assertSame (0 , $ this ->queue ->countReserved ());
235235 }
236236
237237 /**
@@ -242,9 +242,9 @@ public function countReservedReturnsNumberOfReservedMessages()
242242 $ messageId = $ this ->queue ->submit ('A message ' );
243243
244244 $ this ->queue ->waitAndReserve (1 );
245- $ this -> assertSame (1 , $ this ->queue ->countReserved ());
245+ self :: assertSame (1 , $ this ->queue ->countReserved ());
246246
247247 $ this ->queue ->abort ($ messageId );
248- $ this -> assertSame (0 , $ this ->queue ->countReserved ());
248+ self :: assertSame (0 , $ this ->queue ->countReserved ());
249249 }
250250}
0 commit comments