Closed HUHANK closed 5 months ago
发一下没用registerMessageListener
函数的代码
掉用
registerMessageListener
函数的代码
try
{
m_consumer_handler = new DefaultMQPushConsumer(m_consumer_group_name);
m_consumer_handler->setNamesrvAddr(m_namesrv_addr);
m_consumer_handler->setGroupName(m_consumer_group_name);
m_consumer_handler->setConsumeFromWhere(CONSUME_FROM_LAST_OFFSET);
m_consumer_handler->subscribe(m_consumer_topic, "*");
m_consumer_handler->setConsumeThreadCount(1);
m_consumer_handler->setConsumeMessageBatchMaxSize(31);
m_consumer_handler->setAsyncPull(true);
m_consumer_msg_listener = new ConsumerMsgListener(this);
m_consumer_handler->registerMessageListener(m_consumer_msg_listener);
m_consumer_handler->start();
}
catch (const MQClientException &e)
{
LOG_ERROR(e.what());
return false;
}
@HUHANK /home/code/share/mq/mf_rocketmq.cpp:32 这行代码是什么?
@HUHANK /home/code/share/mq/mf_rocketmq.cpp:32 这行代码是什么?
@HUHANK CRocketMQMessageHandler
类型的定义,和运行时m_msg_handler
成员变量的值是什么呢?
看起来m_msg_handler
没有指向一个完整的类型。
没有指向一个完整的类型 嗯,我再测一下,把m_msg_handler相关代码从ConsumerMsgListener拿掉试试
@ifplusor
请问,我怎么样调整vector
该问题是我代码的问题,与rocketmq-client-cpp-2.2.0的api无关,谢谢 @ifplusor 的指点。
@ifplusor 请问,我怎么样调整vector的大小,我测试发现默认size都是1,要通过那个设置函数设置这个的大小。
目前不支持,硬编码了1
@ifplusor 请问,我怎么样调整vector的大小,我测试发现默认size都是1,要通过那个设置函数设置这个的大小。
目前不支持,硬编码了1
Ths!
程序运行系统:CentOS7
崩溃截图如下:
下面是GDB的调用堆栈信息:
下面是我的关键代码片段:
个人觉得是官方API的BUG,如果有大神遇到过类似问题,并解决的希望不宁赐教,请官方确认一下这个问题,谢谢!