Commit ff03da02 authored by yanzg's avatar yanzg

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

parent ec72a6be
...@@ -38,7 +38,7 @@ public class MessageVo extends BaseVo implements InitDao { ...@@ -38,7 +38,7 @@ public class MessageVo extends BaseVo implements InitDao {
/** /**
* 延迟毫秒 * 延迟毫秒
*/ */
private long dedTime; private int dedTime;
/** /**
* 处理次数 * 处理次数
...@@ -124,7 +124,7 @@ public class MessageVo extends BaseVo implements InitDao { ...@@ -124,7 +124,7 @@ public class MessageVo extends BaseVo implements InitDao {
this.exchangeName = exchangeName; this.exchangeName = exchangeName;
this.routeKey = routeKey; this.routeKey = routeKey;
this.message = message; this.message = message;
this.dedTime = dedTime; this.dedTime = (int) dedTime;
} }
/** /**
...@@ -174,11 +174,11 @@ public class MessageVo extends BaseVo implements InitDao { ...@@ -174,11 +174,11 @@ public class MessageVo extends BaseVo implements InitDao {
this.message = message; this.message = message;
} }
public long getDedTime() { public int getDedTime() {
return dedTime; return dedTime;
} }
public void setDedTime(long dedTime) { public void setDedTime(int dedTime) {
this.dedTime = 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