@@ -50,8 +50,6 @@ else if(!empty($VVERBOSE)) {
50
50
$ logLevel = true ;
51
51
}
52
52
53
- $ logger = new Resque_Log ($ logLevel );
54
-
55
53
$ APP_INCLUDE = getenv ('APP_INCLUDE ' );
56
54
if ($ APP_INCLUDE ) {
57
55
if (!file_exists ($ APP_INCLUDE )) {
@@ -61,6 +59,12 @@ if($APP_INCLUDE) {
61
59
require_once $ APP_INCLUDE ;
62
60
}
63
61
62
+ // See if the APP_INCLUDE containes a logger object,
63
+ // If none exists, fallback to internal logger
64
+ if (!isset ($ logger ) && !is_object ($ logger )) {
65
+ $ logger = new Resque_Log ($ logLevel );
66
+ }
67
+
64
68
$ BLOCKING = getenv ('BLOCKING ' ) !== FALSE ;
65
69
66
70
$ interval = 5 ;
@@ -92,7 +96,7 @@ if($count > 1) {
92
96
else if (!$ pid ) {
93
97
$ queues = explode (', ' , $ QUEUE );
94
98
$ worker = new Resque_Worker ($ queues );
95
- $ worker ->setLogger (new Resque_Log ( $ logLevel ) );
99
+ $ worker ->setLogger ($ logger );
96
100
$ logger ->log (Psr \Log \LogLevel::NOTICE , 'Starting worker {worker} ' , array ('worker ' => $ worker ));
97
101
$ worker ->work ($ interval , $ BLOCKING );
98
102
break ;
@@ -103,7 +107,7 @@ if($count > 1) {
103
107
else {
104
108
$ queues = explode (', ' , $ QUEUE );
105
109
$ worker = new Resque_Worker ($ queues );
106
- $ worker ->setLogger (new Resque_Log ( $ logLevel ) );
110
+ $ worker ->setLogger ($ logger );
107
111
108
112
$ PIDFILE = getenv ('PIDFILE ' );
109
113
if ($ PIDFILE ) {
0 commit comments