发送延迟消息报错 确认topic是延迟消息

[dayuange123]

从阿里云后台确认topic是延迟消息。但是sdk发送消息抛异常。org.springframework.messaging.MessagingException: CODE: 13 DESC: TopicMessageType validate failed, the expected type is DELAY, but actual type is NORMAL BROKER

[francisoliverlee]

ref rocketmq-clients#discussions#785

可以把rocketmq-spring的版本、发送消息的代码贴一下， 确认下sdk的逻辑

[dayuange123]

解决了 看起来是延迟时间不能传0的问题

[francisoliverlee]

应该是这段代码有问题：延迟为0时， 没有设置延迟扩展字段。
broker是根据这个扩展字段校验topic type；
应该校验下延迟值， 只能大于等于0

rocketmq-spring/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java

Lines 635 to 652 in 11aa3af

	try {
	long now = System.currentTimeMillis();
	org.apache.rocketmq.common.message.Message rocketMsg = this.createRocketMqMessage(destination, message);
	if (delayTime > 0 && Objects.nonNull(mode)) {
	switch (mode) {
	case DELAY_SECONDS:
	rocketMsg.setDelayTimeSec(delayTime);
	break;
	case DELAY_MILLISECONDS:
	rocketMsg.setDelayTimeMs(delayTime);
	break;
	case DELIVER_TIME_MILLISECONDS:
	rocketMsg.setDeliverTimeMs(delayTime);
	break;
	default:
	log.warn("delay mode: {} not support", mode);
	}
	}