test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-12-04 04:37:46 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

Merge pull request #1288 from limingxinleo/1.1-queue

Browse Source 
Added driver object into Hyperf\AsyncQueue\Event\QueueLength event as the first parameter
This commit is contained in:
黄朝晖 2020-01-24 13:23:07 +08:00 committed by GitHub
commit 5f43f74541
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/async-queue/src/Driver/Driver.php
View File

@ -112,7 +112,7 @@ abstract class Driver implements DriverInterface
{
$info = $this->info();
foreach ($info as $key => $value) {
$this->event && $this->event->dispatch(new QueueLength($key, $value));
$this->event && $this->event->dispatch(new QueueLength($this, $key, $value));
}
}

10
src/async-queue/src/Event/QueueLength.php
View File

@ -12,8 +12,15 @@ declare(strict_types=1);
namespace Hyperf\AsyncQueue\Event;
use Hyperf\AsyncQueue\Driver\DriverInterface;
class QueueLength
{
/**
* @var DriverInterface
*/
public $driver;
/**
* @var string
*/
@ -24,8 +31,9 @@ class QueueLength
*/
public $length;
public function __construct(string $key, int $length)
public function __construct(DriverInterface $driver, string $key, int $length)
{
$this->driver = $driver;
$this->key = $key;
$this->length = $length;
}