21-RabbitMQ延迟队列插件

https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases

# 进入plugins目录
cd /usr/local/rabbitmq/plugins/

# 启动延迟插件
rabbitmq-plugins enable rabbitmq_delayed_message_exchange

# 在消息转换器中设置到messageProperties中即可
@Override
public Message toMessage(Object o, MessageProperties messageProperties) throws MessageConversionException {
//        messageProperties.setExpiration(defaultExpire);
    com.dance.rabbitmq.api.Message message = (com.dance.rabbitmq.api.Message) o;
    int delayMills = message.getDelayMills();
    messageProperties.setDelay(delayMills);
    return messageConverter.toMessage(o,messageProperties);
}