diff --git a/src/config.php b/src/config.php index e8d615f..0db07fe 100644 --- a/src/config.php +++ b/src/config.php @@ -4,6 +4,10 @@ return [ 'callback_host' => env('mq_callback_host', 'http://192.168.21.170:8085'), 'callback' => '/rocketmq/producer/notify', 'subscribe' => [ + //节点配置 由mq的topic.tag为标识 + // '[topic].[tag]' => [ + // Test:class + // ] ] ]; diff --git a/src/connection/Config.php b/src/connection/Config.php index 6767571..0b315b9 100644 --- a/src/connection/Config.php +++ b/src/connection/Config.php @@ -38,7 +38,7 @@ class Config /** * @return int */ - public function getTimeOut() + public function getTimeOut(): int { return $this->timeOut ?? 60; }