消息队列MQ 无法订阅消息,用的C#示例代码

//创建consumer

        ONSFactory onsfactory = new ONSFactory();
        PushConsumer pConsumer = onsfactory.getInstance().createPushConsumer(factoryInfo);

程序走到这步会报错,日志上“ Input message model is wrong, will use default msg model(CLUSTERING)[..srcons-client-netPushConsumerImpl.cpp:88]” 请问怎么解决

展开
收起
liwj_netcom 2016-11-03 12:08:54 2953 分享 版权
1 条回答
写回答
取消 提交回答
  • 貌似 message model 是个参数,你没有传,使用了默认CLUSTERING。看看是否能指定model参数

    2019-07-17 20:22:12
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理