hyperf / hyperf/nsq

nsq注解不支持重写启动消费进程数量 nums

Open
#6 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
PHP
Stars
4
Forks
5
PR merge metrics
No merged PRs in 30d

Description

ConsumerManager.php中已经写死了用注解传入的参数。
$annotation->topic && $instance->setTopic($annotation->topic);
$annotation->channel && $instance->setChannel($annotation->channel);
$annotation->name && $instance->setName($annotation->name);
$annotation->pool && $instance->setPool($annotation->pool);

$nums = $annotation->nums;
$process = $this->createProcess($instance);
$process->nums = (int) $nums;
$process->name = $instance->getName() . '-' . $instance->getTopic();
ProcessManager::register($process);

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.