2424use Cake \TestSuite \TestCase ;
2525use Enqueue \Null \NullConnectionFactory ;
2626use Enqueue \Null \NullMessage ;
27- use Exception ;
2827use Interop \Queue \Processor as InteropProcessor ;
28+ use TestApp \TestProcessor ;
2929
3030class ProcessorTest extends TestCase
3131{
@@ -36,7 +36,7 @@ class ProcessorTest extends TestCase
3636 *
3737 * @return array
3838 */
39- public function dataProviderTestProcess (): array
39+ public static function dataProviderTestProcess (): array
4040 {
4141 return [
4242 'ack ' => ['processReturnAck ' , InteropProcessor::ACK , 'Message processed sucessfully ' , 'Processor.message.success ' ],
@@ -60,7 +60,7 @@ public function dataProviderTestProcess(): array
6060 public function testProcess ($ jobMethod , $ expected , $ logMessage , $ dispatchedEvent )
6161 {
6262 $ messageBody = [
63- 'class ' => [static ::class, $ jobMethod ],
63+ 'class ' => [TestProcessor ::class, $ jobMethod ],
6464 'args ' => [],
6565 ];
6666 $ connectionFactory = new NullConnectionFactory ();
@@ -140,7 +140,7 @@ public function testProcessWillRequeueOnException()
140140 {
141141 $ method = 'processAndThrowException ' ;
142142 $ messageBody = [
143- 'class ' => [static ::class, $ method ],
143+ 'class ' => [TestProcessor ::class, $ method ],
144144 'data ' => ['sample_data ' => 'a value ' , 'key ' => md5 ($ method )],
145145 ];
146146 $ connectionFactory = new NullConnectionFactory ();
@@ -195,7 +195,7 @@ public function testProcessJobObject()
195195 public function testProcessMessage ()
196196 {
197197 $ messageBody = [
198- 'class ' => [static ::class, 'processReturnAck ' ],
198+ 'class ' => [TestProcessor ::class, 'processReturnAck ' ],
199199 'args ' => [],
200200 ];
201201 $ connectionFactory = new NullConnectionFactory ();
@@ -206,83 +206,6 @@ public function testProcessMessage()
206206
207207 $ result = $ processor ->processMessage ($ message );
208208 $ this ->assertSame (InteropProcessor::ACK , $ result );
209- $ this ->assertNotEmpty (static ::$ lastProcessMessage );
210- }
211-
212- /**
213- * Job to be used in test testProcessMessageCallableIsString
214- *
215- * @param \Cake\Queue\Job\Message $message The message to process
216- * @return null
217- */
218- public static function processReturnNull (Message $ message )
219- {
220- static ::$ lastProcessMessage = $ message ;
221-
222- return null ;
223- }
224-
225- /**
226- * Job to be used in test testProcessMessageCallableIsString
227- *
228- * @param Message $message The message to process
229- * @return null
230- * @throws Exception
231- */
232- public static function processAndThrowException (Message $ message )
233- {
234- throw new Exception ('Something went wrong ' );
235- }
236-
237- /**
238- * Job to be used in test testProcessMessageCallableIsString
239- *
240- * @param \Cake\Queue\Message $message The message to process
241- * @return null
242- */
243- public static function processReturnReject (Message $ message )
244- {
245- static ::$ lastProcessMessage = $ message ;
246-
247- return InteropProcessor::REJECT ;
248- }
249-
250- /**
251- * Job to be used in test testProcessMessageCallableIsString
252- *
253- * @param \Cake\Queue\Message $message The message to process
254- * @return null
255- */
256- public static function processReturnAck (Message $ message )
257- {
258- static ::$ lastProcessMessage = $ message ;
259-
260- return InteropProcessor::ACK ;
261- }
262-
263- /**
264- * Job to be used in test testProcessMessageCallableIsString
265- *
266- * @param \Cake\Queue\Message $message The message to process
267- * @return null
268- */
269- public static function processReturnRequeue (Message $ message )
270- {
271- static ::$ lastProcessMessage = $ message ;
272-
273- return InteropProcessor::REQUEUE ;
274- }
275-
276- /**
277- * Job to be used in test testProcessMessageCallableIsString
278- *
279- * @param \Cake\Queue\Message $message The message to process
280- * @return null
281- */
282- public static function processReturnString (Message $ message )
283- {
284- static ::$ lastProcessMessage = $ message ;
285-
286- return 'invalid value ' ;
209+ $ this ->assertNotEmpty (TestProcessor::$ lastProcessMessage );
287210 }
288211}
0 commit comments