baobeisuper opened a new pull request, #473:
URL: https://github.com/apache/rocketmq-clients/pull/473
public MessageQueueImpl(apache.rocketmq.v2.MessageQueue messageQueue) {
this.topicResource = new Resource(messageQueue.getTopic());
this.queueId = messageQueue.getId();
final apache.rocketmq.v2.Permission perm =
messageQueue.getPermission();
this.permission = Permission.fromProtobuf(perm);
this.acceptMessageTypes = new ArrayList<>();
final List<apache.rocketmq.v2.MessageType> types =
messageQueue.getAcceptMessageTypesList();
for (apache.rocketmq.v2.MessageType type : types) {
// 原内容 版本：rocketmq-client-java 5.0.4 及 5.0.6-SNAPSHOT
// acceptMessageTypes.add(MessageType.fromProtobuf(type));
// Super Update 20230413 不加此判断，按照官网和其它网上的示例。根本运行不起来
// 官网：快速开始
https://rocketmq.apache.org/zh/docs/quickStart/01quickstart
// 提示：Message type is not specified
if (apache.rocketmq.v2.MessageType.MESSAGE_TYPE_UNSPECIFIED !=
type) {
acceptMessageTypes.add(MessageType.fromProtobuf(type));
}
}
this.broker = new Broker(messageQueue.getBroker());
}
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
