package com.yanzuoguang.mq.vo; import com.yanzuoguang.util.vo.BaseVo; /** * 消息计划 * * @author 颜佐光 */ public class MessagePlan extends BaseVo { /** * 开始时间 */ private long start; /** * 消息 */ private MessageVo message; public MessagePlan() { this.start = System.currentTimeMillis(); } public MessagePlan(MessageVo message) { this(); this.message = message; } public MessagePlan(long start, MessageVo message) { this.start = start; this.message = message; } public long getStart() { return start; } public void setStart(long start) { this.start = start; } public long getWaitTime() { if (this.message == null) { return 0; } long time = System.currentTimeMillis() - this.getStart(); long dedTime = this.message.getDedTime() - time; return Math.max(dedTime, 0); } public MessageVo getMessage() { return message; } public void setMessage(MessageVo message) { this.message = message; } }