初学RocketMQ写了一个简单发送消息的一个功能 发现报错了
检查了ip啥的都没问题,端口也开放了
最后发现:
////发送消息 //SendResult result = producer.send(message,100);
这句代码的问题,如果把这个100这个参数去除掉,就能够正常发送消息,RocketMQ图形控制台也能查询到该消息
但是一旦加上后面这个产生就会抛 sendDefaultImpl call timeout异常 这是怎么回事!
初学RocketMQ写了一个简单发送消息的一个功能 发现报错了
检查了ip啥的都没问题,端口也开放了
最后发现:
////发送消息 //SendResult result = producer.send(message,100);
这句代码的问题,如果把这个100这个参数去除掉,就能够正常发送消息,RocketMQ图形控制台也能查询到该消息
但是一旦加上后面这个产生就会抛 sendDefaultImpl call timeout异常 这是怎么回事!