public DatabaseQueue::garbageCollection()
Cleans queues of garbage.
Overrides QueueGarbageCollectionInterface::garbageCollection
File
- core/lib/Drupal/Core/Queue/DatabaseQueue.php, line 215
Class
- DatabaseQueue
- Default queue implementation.
Namespace
Drupal\Core\Queue
Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | public function garbageCollection() { try { // Clean up the queue for failed batches. $this ->connection-> delete ( static ::TABLE_NAME) ->condition( 'created' , REQUEST_TIME - 864000, '<' ) ->condition( 'name' , 'drupal_batch:%' , 'LIKE' ) ->execute(); // Reset expired items in the default queue implementation table. If that's // not used, this will simply be a no-op. $this ->connection->update( static ::TABLE_NAME) ->fields( array ( 'expire' => 0, )) ->condition( 'expire' , 0, '<>' ) ->condition( 'expire' , REQUEST_TIME, '<' ) ->execute(); } catch (\Exception $e ) { $this ->catchException( $e ); } } |
Please login to continue.