Commit 5385434a by YG8999

设备操作,redis队列下发消息

parent 38a82faf
...@@ -265,7 +265,7 @@ public class RedisUtil { ...@@ -265,7 +265,7 @@ public class RedisUtil {
* @param index 下标 * @param index 下标
* @param v 值 * @param v 值
*/ */
public void set(String k, Integer index, Object v) { public void setListByIndex(String k, Integer index, Object v) {
redisTemplate.opsForList().set(k, index, v); redisTemplate.opsForList().set(k, index, v);
} }
......
...@@ -728,7 +728,7 @@ public class MqttxServiceImpl implements MqttxService { ...@@ -728,7 +728,7 @@ public class MqttxServiceImpl implements MqttxService {
// 更新发送次数,并修改重新加入队列 // 更新发送次数,并修改重新加入队列
vo.setRefreshNum(vo.getRefreshNum() + 1); vo.setRefreshNum(vo.getRefreshNum() + 1);
vo.setSendSmsResult(0); vo.setSendSmsResult(0);
redisUtil.set(key, -1, vo); redisUtil.setListByIndex(key, -1, vo);
// 重新发送mqtt消息 // 重新发送mqtt消息
// 异步执行, 间隔5秒 // 异步执行, 间隔5秒
// 延时执行操作 // 延时执行操作
......
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