发送延迟消息无效

[goback619]

发送延迟消息无效。
@OverRide
public void run(String... args) throws Exception {
// int count = 5;
// for (int index = 1; index <= count; index++) {
// source.output().send(MessageBuilder.withPayload("msg-" + index)
// .setHeader("index", index).build());
// }
source.output().send(MessageBuilder
.withPayload(objectMapper.writeValueAsString(new Person(99, "Jim")))
.setHeader("index", 9999)
.setHeader("DELAY", "5")
.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON)
.build());
}