File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -117,25 +117,29 @@ private function registerEvents(): void
117117 }
118118 });
119119
120- $ events ->listen (QueuePaused::class, function (QueuePaused $ event ) {
121- $ queue = Queue::connection ($ event ->connection );
120+ if (class_exists ('Illuminate\Queue\Events\QueuePaused ' )) {
121+ $ events ->listen (QueuePaused::class, function (QueuePaused $ event ) {
122+ $ queue = Queue::connection ($ event ->connection );
122123
123- if (! $ queue instanceof CloudTasksQueue) {
124- return ;
125- }
124+ if (! $ queue instanceof CloudTasksQueue) {
125+ return ;
126+ }
126127
127- $ queue ->pause ($ event ->queue );
128- });
128+ $ queue ->pause ($ event ->queue );
129+ });
130+ }
129131
130- $ events ->listen (QueueResumed::class, function (QueueResumed $ event ) {
131- $ queue = Queue::connection ($ event ->connection );
132+ if (class_exists ('Illuminate\Queue\Events\QueueResumed ' )) {
133+ $ events ->listen (QueueResumed::class, function (QueueResumed $ event ) {
134+ $ queue = Queue::connection ($ event ->connection );
132135
133- if (! $ queue instanceof CloudTasksQueue) {
134- return ;
135- }
136+ if (! $ queue instanceof CloudTasksQueue) {
137+ return ;
138+ }
136139
137- $ queue ->resume ($ event ->queue );
138- });
140+ $ queue ->resume ($ event ->queue );
141+ });
142+ }
139143 }
140144
141145 private function registerCommands (): void
You can’t perform that action at this time.
0 commit comments