activeMQ对STOMP协议支持expire和delay

//延迟100s后消费,AMQ_SCHEDULED_CRON 配置cron表达式
headers.set("AMQ_SCHEDULED_DELAY", Long.toString(100*1000));
//10s没有消费就过期
headers.set("expires", Integer.toString(10*1000));
session.send(headers, "welcome to javacoder.cn");

Posted in: spring practise