You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/03/03 01:10:27 UTC

[GitHub] [rocketmq-client-cpp] BrentHuang opened a new issue #270: 能对接aliyun吗

BrentHuang opened a new issue #270: 能对接aliyun吗
URL: https://github.com/apache/rocketmq-client-cpp/issues/270
 
 
   version： 2.0.1
   
   我的消费者（default push consumer）程序已经正确启动了，在阿里云rocketmq控制台上发送一条消息，我的消费者程序可以收到，这个是通的。
   
   但是在阿里云rocketmq控制台上点“消费验证”，却一直是失败，我的消费者程序也没有收到消息。
   
   并且通过阿里云规则引擎流转到阿里云rocketmq的消息，我的消费者程序也没有收到。
   
   topic和group id都没有问题。
   
   请问是什么原因呢，能帮忙分析一下吗？

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

[GitHub] [rocketmq-client-cpp] ShannonDing closed issue #270: How to connect aliyun MQ?

Posted by GitBox <gi...@apache.org>.
ShannonDing closed issue #270: How to connect aliyun MQ?
URL: https://github.com/apache/rocketmq-client-cpp/issues/270
 
 
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

[GitHub] [rocketmq-client-cpp] BrentHuang commented on issue #270: 能对接aliyun吗

Posted by GitBox <gi...@apache.org>.
BrentHuang commented on issue #270: 能对接aliyun吗
URL: https://github.com/apache/rocketmq-client-cpp/issues/270#issuecomment-593755938
 
 
     consumer.setNamesrvDomain(info.namesrv_domain);
   这个namesrv_domain填什么呢？

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

[GitHub] [rocketmq-client-cpp] BrentHuang commented on issue #270: 能对接aliyun吗

Posted by GitBox <gi...@apache.org>.
BrentHuang commented on issue #270: 能对接aliyun吗
URL: https://github.com/apache/rocketmq-client-cpp/issues/270#issuecomment-593758080
 
 
   已经搞定，instance name是必填的。

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

[GitHub] [rocketmq-client-cpp] BrentHuang commented on issue #270: How to connect aliyun MQ?

Posted by GitBox <gi...@apache.org>.
BrentHuang commented on issue #270: How to connect aliyun MQ?
URL: https://github.com/apache/rocketmq-client-cpp/issues/270#issuecomment-593826994
 
 
   循环中，如果遇到消费失败的，就返回RECONSUME_LATER吗？该消息及其后的消息都会在下一次回调的时候传过来？

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

[GitHub] [rocketmq-client-cpp] BrentHuang commented on issue #270: How to connect aliyun MQ?

Posted by GitBox <gi...@apache.org>.
BrentHuang commented on issue #270: How to connect aliyun MQ?
URL: https://github.com/apache/rocketmq-client-cpp/issues/270#issuecomment-593814289
 
 
   class RocketMQMsgListener : public rocketmq::MessageListenerConcurrently
   {
   public:
       RocketMQMsgListener() {}
       virtual ~RocketMQMsgListener() {}
   
       virtual rocketmq::ConsumeStatus consumeMessage(const std::vector<rocketmq::MQMessageExt>& msgs)
       {
           for (size_t i = 0; i < msgs.size(); ++i)
           {
               callback_(msgs[i].getTopic(), msgs[i].getTags(), msgs[i].getMsgId(), msgs[i].getBody());
           }
   
           return rocketmq::CONSUME_SUCCESS;
       }
   
   请问，这个回调接口的参数是一个msg的vector，在其中我循环消费每一个消息，然后总体返回一个CONSUME_SUCCESS。那么如果有的消息消费失败了，有的消费成功了，怎么办呢？总体返回一个CONSUME_SUCCESS不行吧？对于每一个消息的具体消费情况，怎么给服务器答复呢？
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services