3
3
namespace Enqueue \JobQueue \Tests ;
4
4
5
5
use Enqueue \Client \Message ;
6
- use Enqueue \Client \MessageProducerInterface ;
6
+ use Enqueue \Client \ProducerInterface ;
7
7
use Enqueue \Consumption \Result ;
8
8
use Enqueue \JobQueue \DependentJobProcessor ;
9
9
use Enqueue \JobQueue \Job ;
@@ -27,7 +27,7 @@ public function testShouldLogCriticalAndRejectMessageIfJobIdIsNotSet()
27
27
{
28
28
$ jobStorage = $ this ->createJobStorageMock ();
29
29
30
- $ producer = $ this ->createMessageProducerMock ();
30
+ $ producer = $ this ->createProducerMock ();
31
31
32
32
$ logger = $ this ->createLoggerMock ();
33
33
$ logger
@@ -55,7 +55,7 @@ public function testShouldLogCriticalAndRejectMessageIfJobEntityWasNotFound()
55
55
->with (12345 )
56
56
;
57
57
58
- $ producer = $ this ->createMessageProducerMock ();
58
+ $ producer = $ this ->createProducerMock ();
59
59
60
60
$ logger = $ this ->createLoggerMock ();
61
61
$ logger
@@ -87,7 +87,7 @@ public function testShouldLogCriticalAndRejectMessageIfJobIsNotRoot()
87
87
->will ($ this ->returnValue ($ job ))
88
88
;
89
89
90
- $ producer = $ this ->createMessageProducerMock ();
90
+ $ producer = $ this ->createProducerMock ();
91
91
92
92
$ logger = $ this ->createLoggerMock ();
93
93
$ logger
@@ -118,7 +118,7 @@ public function testShouldDoNothingIfDependentJobsAreMissing()
118
118
->will ($ this ->returnValue ($ job ))
119
119
;
120
120
121
- $ producer = $ this ->createMessageProducerMock ();
121
+ $ producer = $ this ->createProducerMock ();
122
122
$ producer
123
123
->expects ($ this ->never ())
124
124
->method ('send ' )
@@ -154,7 +154,7 @@ public function testShouldLogCriticalAndRejectMessageIfDependentJobTopicIsMissin
154
154
->will ($ this ->returnValue ($ job ))
155
155
;
156
156
157
- $ producer = $ this ->createMessageProducerMock ();
157
+ $ producer = $ this ->createProducerMock ();
158
158
$ producer
159
159
->expects ($ this ->never ())
160
160
->method ('send ' )
@@ -197,7 +197,7 @@ public function testShouldLogCriticalAndRejectMessageIfDependentJobMessageIsMiss
197
197
->will ($ this ->returnValue ($ job ))
198
198
;
199
199
200
- $ producer = $ this ->createMessageProducerMock ();
200
+ $ producer = $ this ->createProducerMock ();
201
201
$ producer
202
202
->expects ($ this ->never ())
203
203
->method ('send ' )
@@ -243,7 +243,7 @@ public function testShouldPublishDependentMessage()
243
243
;
244
244
245
245
$ expectedMessage = null ;
246
- $ producer = $ this ->createMessageProducerMock ();
246
+ $ producer = $ this ->createProducerMock ();
247
247
$ producer
248
248
->expects ($ this ->once ())
249
249
->method ('send ' )
@@ -291,7 +291,7 @@ public function testShouldPublishDependentMessageWithPriority()
291
291
;
292
292
293
293
$ expectedMessage = null ;
294
- $ producer = $ this ->createMessageProducerMock ();
294
+ $ producer = $ this ->createProducerMock ();
295
295
$ producer
296
296
->expects ($ this ->once ())
297
297
->method ('send ' )
@@ -333,11 +333,11 @@ private function createJobStorageMock()
333
333
}
334
334
335
335
/**
336
- * @return \PHPUnit_Framework_MockObject_MockObject|MessageProducerInterface
336
+ * @return \PHPUnit_Framework_MockObject_MockObject|ProducerInterface
337
337
*/
338
- private function createMessageProducerMock ()
338
+ private function createProducerMock ()
339
339
{
340
- return $ this ->createMock (MessageProducerInterface ::class);
340
+ return $ this ->createMock (ProducerInterface ::class);
341
341
}
342
342
343
343
/**
0 commit comments