fix mq log control
This commit is contained in:
@@ -569,7 +569,7 @@ void Front::mqconsumerThread()
|
|||||||
|
|
||||||
|
|
||||||
// ✅ 必须在 start() 之前设置
|
// ✅ 必须在 start() 之前设置
|
||||||
m_mqConsumer->setLogPath("/data/logs/rocketmq"); // 目录
|
//m_mqConsumer->setLogPath("/data/logs/rocketmq"); // 目录
|
||||||
m_mqConsumer->setLogLevel(rocketmq::eLOG_LEVEL_ERROR); // 级别(error)
|
m_mqConsumer->setLogLevel(rocketmq::eLOG_LEVEL_ERROR); // 级别(error)
|
||||||
m_mqConsumer->setLogFileSizeAndNum(5, 50); // 5 个文件,每个 50MB
|
m_mqConsumer->setLogFileSizeAndNum(5, 50); // 5 个文件,每个 50MB
|
||||||
|
|
||||||
|
|||||||
@@ -182,7 +182,7 @@ RocketMQProducer::RocketMQProducer(const std::string& groupName,
|
|||||||
: producer_(groupName) {
|
: producer_(groupName) {
|
||||||
|
|
||||||
// ✅ 必须在 start() 之前设置
|
// ✅ 必须在 start() 之前设置
|
||||||
producer_.setLogPath("/data/logs/rocketmq"); // 目录
|
//producer_.setLogPath("/data/logs/rocketmq"); // 目录
|
||||||
producer_.setLogLevel(rocketmq::eLOG_LEVEL_ERROR); // 级别(error)
|
producer_.setLogLevel(rocketmq::eLOG_LEVEL_ERROR); // 级别(error)
|
||||||
producer_.setLogFileSizeAndNum(5, 50); // 5 个文件,每个 50MB
|
producer_.setLogFileSizeAndNum(5, 50); // 5 个文件,每个 50MB
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user