Commit 2f292caa authored by yanzg's avatar yanzg

修改MQ请求尸体,防止出错

parent ff03da02
...@@ -108,7 +108,7 @@ public class MessageVo extends BaseVo implements InitDao { ...@@ -108,7 +108,7 @@ public class MessageVo extends BaseVo implements InitDao {
* @param message 消息内容 * @param message 消息内容
* @param dedTime 过期时间 * @param dedTime 过期时间
*/ */
public MessageVo(String exchangeNameRouteKey, String message, long dedTime) { public MessageVo(String exchangeNameRouteKey, String message, int dedTime) {
this(exchangeNameRouteKey, exchangeNameRouteKey, message, dedTime); this(exchangeNameRouteKey, exchangeNameRouteKey, message, dedTime);
} }
...@@ -120,11 +120,11 @@ public class MessageVo extends BaseVo implements InitDao { ...@@ -120,11 +120,11 @@ public class MessageVo extends BaseVo implements InitDao {
* @param message 消息内容 * @param message 消息内容
* @param dedTime 过期时间 * @param dedTime 过期时间
*/ */
public MessageVo(String exchangeName, String routeKey, String message, long dedTime) { public MessageVo(String exchangeName, String routeKey, String message, int dedTime) {
this.exchangeName = exchangeName; this.exchangeName = exchangeName;
this.routeKey = routeKey; this.routeKey = routeKey;
this.message = message; this.message = message;
this.dedTime = (int) dedTime; this.dedTime = dedTime;
} }
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment