https://help.aliyun.com/document_detail/43349.html?spm=a2c4g.11186631.6.552.20227ea1qoLgio

是支持的 头信息传入 [__STARTDELIVERTIME]: 指定时间

DefaultMQProducerImpl 的 739行... 不知道为啥官方不在加个header的key~

__STARTDELIVERTIME 设过了然而不起作用

RocketMQ Binder 现在只支持 DELAY 这个 header

DELAY 这个header 在开源的RocketMq是可以用 但是在阿里云RocketMq 也是起不了作用！

期望尽早支持这个特性

@jojozoo 开源是Delay 传入等级，阿里云是__STARTDELIVERTIME 传入指定时间，阿里云上面必须建延迟topic，不是普通类型。。 目前正在用。。。

可以发个示例代码？

    Message<String> msgBody = MessageBuilder
            .withPayload("12345")
            .setHeader("__STARTDELIVERTIME", "2019-07-31 15:20:01")
            .build();

@Nitsuya 可以发个示例代码？

@jojozoo 就是你发的这样，走的topic要走阿里云的延迟topic。 我用的 版本0.9.0

我这边死活不成功 怎么设置都是死活延时1分30秒左右

@fangjian0423 能做个官方demo?

@jojozoo

producer code snipper:

Message msg = MessageBuilder.withPayload("simple msg")
				.setHeader("DELAY", 3).build();
source.output().send(msg);
System.out.println("msg send at " + DateFormatUtils
		.format(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss"));

configurations:

spring.cloud.stream.rocketmq.binder.name-server=nameServerInAliwareMQ
spring.cloud.stream.rocketmq.binder.access-key=ak
spring.cloud.stream.rocketmq.binder.secret-key=sk

spring.cloud.stream.bindings.output.destination=instanceId%test-topic
spring.cloud.stream.bindings.output.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output.producer.sync=true

need __STARTDELIVERTIME header

@Nitsuya DefaultMQProducerImpl 的 739行... 不知道为啥官方不在加个header的key~
https://github.com/apache/rocketmq/blob/8e44ca1ff1c8a8c3513cc88087c83db04973a47a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java#L739
这里要加什么

need __STARTDELIVERTIME header

@jojozoo
这里不加东西啊。
你发的这个链接是 752行，开源版本是写死的。。
我的意思是为啥开源版本不加个header，干嘛在里面写死的。

正确的例子是这样的：
`
setHeader("__STARTDELIVERTIME", new Date().getTime() + 你要延迟的毫秒)
`

@Nitsuya 我这边测试成功了 就是云上控制台上消息查询不出了

@jojozoo #764 (comment)

@fangjian0423 按照你的配置使用output默认Source是可以的。但是自定义source跟源码sync源码未赋值
比如：spring.cloud.stream.rocketmq.bindings.expresstimeout.producer.sync=true