@@ -11,7 +11,7 @@ class Resque_Tests_WorkerTest extends Resque_Tests_TestCase
1111 public function testWorkerRegistersInList ()
1212 {
1313 $ worker = new Resque_Worker ('* ' );
14- $ worker ->setLogger (new Resque_Log () );
14+ $ worker ->setLogger ($ this -> logger );
1515 $ worker ->registerWorker ();
1616
1717 // Make sure the worker is in the list
@@ -24,7 +24,7 @@ public function testGetAllWorkers()
2424 // Register a few workers
2525 for ($ i = 0 ; $ i < $ num ; ++$ i ) {
2626 $ worker = new Resque_Worker ('queue_ ' . $ i );
27- $ worker ->setLogger (new Resque_Log () );
27+ $ worker ->setLogger ($ this -> logger );
2828 $ worker ->registerWorker ();
2929 }
3030
@@ -35,7 +35,7 @@ public function testGetAllWorkers()
3535 public function testGetWorkerById ()
3636 {
3737 $ worker = new Resque_Worker ('* ' );
38- $ worker ->setLogger (new Resque_Log () );
38+ $ worker ->setLogger ($ this -> logger );
3939 $ worker ->registerWorker ();
4040
4141 $ newWorker = Resque_Worker::find ((string )$ worker );
@@ -50,7 +50,7 @@ public function testInvalidWorkerDoesNotExist()
5050 public function testWorkerCanUnregister ()
5151 {
5252 $ worker = new Resque_Worker ('* ' );
53- $ worker ->setLogger (new Resque_Log () );
53+ $ worker ->setLogger ($ this -> logger );
5454 $ worker ->registerWorker ();
5555 $ worker ->unregisterWorker ();
5656
@@ -62,7 +62,7 @@ public function testWorkerCanUnregister()
6262 public function testPausedWorkerDoesNotPickUpJobs ()
6363 {
6464 $ worker = new Resque_Worker ('* ' );
65- $ worker ->setLogger (new Resque_Log () );
65+ $ worker ->setLogger ($ this -> logger );
6666 $ worker ->pauseProcessing ();
6767 Resque::enqueue ('jobs ' , 'Test_Job ' );
6868 $ worker ->work (0 );
@@ -73,7 +73,7 @@ public function testPausedWorkerDoesNotPickUpJobs()
7373 public function testResumedWorkerPicksUpJobs ()
7474 {
7575 $ worker = new Resque_Worker ('* ' );
76- $ worker ->setLogger (new Resque_Log () );
76+ $ worker ->setLogger ($ this -> logger );
7777 $ worker ->pauseProcessing ();
7878 Resque::enqueue ('jobs ' , 'Test_Job ' );
7979 $ worker ->work (0 );
@@ -89,7 +89,7 @@ public function testWorkerCanWorkOverMultipleQueues()
8989 'queue1 ' ,
9090 'queue2 '
9191 ));
92- $ worker ->setLogger (new Resque_Log () );
92+ $ worker ->setLogger ($ this -> logger );
9393 $ worker ->registerWorker ();
9494 Resque::enqueue ('queue1 ' , 'Test_Job_1 ' );
9595 Resque::enqueue ('queue2 ' , 'Test_Job_2 ' );
@@ -108,7 +108,7 @@ public function testWorkerWorksQueuesInSpecifiedOrder()
108108 'medium ' ,
109109 'low '
110110 ));
111- $ worker ->setLogger (new Resque_Log () );
111+ $ worker ->setLogger ($ this -> logger );
112112 $ worker ->registerWorker ();
113113
114114 // Queue the jobs in a different order
@@ -130,7 +130,7 @@ public function testWorkerWorksQueuesInSpecifiedOrder()
130130 public function testWildcardQueueWorkerWorksAllQueues ()
131131 {
132132 $ worker = new Resque_Worker ('* ' );
133- $ worker ->setLogger (new Resque_Log () );
133+ $ worker ->setLogger ($ this -> logger );
134134 $ worker ->registerWorker ();
135135
136136 Resque::enqueue ('queue1 ' , 'Test_Job_1 ' );
@@ -146,7 +146,7 @@ public function testWildcardQueueWorkerWorksAllQueues()
146146 public function testWorkerDoesNotWorkOnUnknownQueues ()
147147 {
148148 $ worker = new Resque_Worker ('queue1 ' );
149- $ worker ->setLogger (new Resque_Log () );
149+ $ worker ->setLogger ($ this -> logger );
150150 $ worker ->registerWorker ();
151151 Resque::enqueue ('queue2 ' , 'Test_Job ' );
152152
@@ -157,7 +157,7 @@ public function testWorkerClearsItsStatusWhenNotWorking()
157157 {
158158 Resque::enqueue ('jobs ' , 'Test_Job ' );
159159 $ worker = new Resque_Worker ('jobs ' );
160- $ worker ->setLogger (new Resque_Log () );
160+ $ worker ->setLogger ($ this -> logger );
161161 $ job = $ worker ->reserve ();
162162 $ worker ->workingOn ($ job );
163163 $ worker ->doneWorking ();
@@ -167,7 +167,7 @@ public function testWorkerClearsItsStatusWhenNotWorking()
167167 public function testWorkerRecordsWhatItIsWorkingOn ()
168168 {
169169 $ worker = new Resque_Worker ('jobs ' );
170- $ worker ->setLogger (new Resque_Log () );
170+ $ worker ->setLogger ($ this -> logger );
171171 $ worker ->registerWorker ();
172172
173173 $ payload = array (
@@ -190,7 +190,7 @@ public function testWorkerErasesItsStatsWhenShutdown()
190190 Resque::enqueue ('jobs ' , 'Invalid_Job ' );
191191
192192 $ worker = new Resque_Worker ('jobs ' );
193- $ worker ->setLogger (new Resque_Log () );
193+ $ worker ->setLogger ($ this -> logger );
194194 $ worker ->work (0 );
195195 $ worker ->work (0 );
196196
@@ -202,18 +202,18 @@ public function testWorkerCleansUpDeadWorkersOnStartup()
202202 {
203203 // Register a good worker
204204 $ goodWorker = new Resque_Worker ('jobs ' );
205- $ goodWorker ->setLogger (new Resque_Log () );
205+ $ goodWorker ->setLogger ($ this -> logger );
206206 $ goodWorker ->registerWorker ();
207207 $ workerId = explode (': ' , $ goodWorker );
208208
209209 // Register some bad workers
210210 $ worker = new Resque_Worker ('jobs ' );
211- $ worker ->setLogger (new Resque_Log () );
211+ $ worker ->setLogger ($ this -> logger );
212212 $ worker ->setId ($ workerId [0 ].':1:jobs ' );
213213 $ worker ->registerWorker ();
214214
215215 $ worker = new Resque_Worker (array ('high ' , 'low ' ));
216- $ worker ->setLogger (new Resque_Log () );
216+ $ worker ->setLogger ($ this -> logger );
217217 $ worker ->setId ($ workerId [0 ].':2:high,low ' );
218218 $ worker ->registerWorker ();
219219
@@ -229,14 +229,14 @@ public function testDeadWorkerCleanUpDoesNotCleanUnknownWorkers()
229229 {
230230 // Register a bad worker on this machine
231231 $ worker = new Resque_Worker ('jobs ' );
232- $ worker ->setLogger (new Resque_Log () );
232+ $ worker ->setLogger ($ this -> logger );
233233 $ workerId = explode (': ' , $ worker );
234234 $ worker ->setId ($ workerId [0 ].':1:jobs ' );
235235 $ worker ->registerWorker ();
236236
237237 // Register some other false workers
238238 $ worker = new Resque_Worker ('jobs ' );
239- $ worker ->setLogger (new Resque_Log () );
239+ $ worker ->setLogger ($ this -> logger );
240240 $ worker ->setId ('my.other.host:1:jobs ' );
241241 $ worker ->registerWorker ();
242242
@@ -253,7 +253,7 @@ public function testDeadWorkerCleanUpDoesNotCleanUnknownWorkers()
253253 public function testWorkerFailsUncompletedJobsOnExit ()
254254 {
255255 $ worker = new Resque_Worker ('jobs ' );
256- $ worker ->setLogger (new Resque_Log () );
256+ $ worker ->setLogger ($ this -> logger );
257257 $ worker ->registerWorker ();
258258
259259 $ payload = array (
@@ -270,7 +270,7 @@ public function testWorkerFailsUncompletedJobsOnExit()
270270 public function testBlockingListPop ()
271271 {
272272 $ worker = new Resque_Worker ('jobs ' );
273- $ worker ->setLogger (new Resque_Log () );
273+ $ worker ->setLogger ($ this -> logger );
274274 $ worker ->registerWorker ();
275275
276276 Resque::enqueue ('jobs ' , 'Test_Job_1 ' );
@@ -296,9 +296,9 @@ public function testWorkerFailsSegmentationFaultJob()
296296 Resque::enqueue ('jobs ' , 'Test_Infinite_Recursion_Job ' );
297297
298298 $ worker = new Resque_Worker ('jobs ' );
299- $ worker ->setLogger (new Resque_Log () );
299+ $ worker ->setLogger ($ this -> logger );
300300 $ worker ->work (0 );
301301
302302 $ this ->assertEquals (1 , Resque_Stat::get ('failed ' ));
303303 }
304- }
304+ }
0 commit comments