tenweb-speed-optimizer
/
vendor
/
10web-utils
/
10web-queue
/
src
/
TenWebQueue
/
Examples
/
example.php
tenweb-speed-optimizer
/
vendor
/
10web-utils
/
10web-queue
/
src
/
TenWebQueue
/
Examples
Last commit date
QueueConsumer.php
4 years ago
QueueProducer.php
4 years ago
example.php
4 years ago
example.php
25 lines
| 1 | <?php |
| 2 | |
| 3 | use TenWebQueue\QueueOrchestrator; |
| 4 | use TenWebQueue\DTO\QueueConfigDTO; |
| 5 | use TenWebQueue\DTO\QueueDataDTO; |
| 6 | |
| 7 | $name = "test_queue"; |
| 8 | |
| 9 | $q = QueueOrchestrator::initQueue(new QueueConfigDTO([ |
| 10 | 'connection_type' => 'file', |
| 11 | 'file_connection_path' => ABSPATH . 'wp-content', |
| 12 | 'restart_file_path' => '/tenweb_image_optimizer_restart.txt', |
| 13 | 'restart_route' => 'tenwebio/v2/compress', |
| 14 | 'items_count_for_restart' => 20, |
| 15 | 'force' => false, |
| 16 | 'queue_data' => new QueueDataDTO([ |
| 17 | 'name' => $name, |
| 18 | 'data' => [["post_id" => 1, "url" => "example1"], ["post_id" => 2, "url" => "example2"], ["post_id" => 3, "url" => "example3"]], |
| 19 | 'multiple_items' => true, |
| 20 | ]) |
| 21 | ]), \TenWebQueue\Examples\QueueProducer::class, \TenWebQueue\Examples\QueueConsumer::class); |
| 22 | $q->enqueue(); |
| 23 | |
| 24 | $q->dequeue(true); |
| 25 |