| | |
| | | @Override |
| | | public void run() { |
| | | try { |
| | | List<CMQManager.MQMsgConsumeResult> list = CMQManager.getInstance().consumeInvalidDeviceTokenQueue(16); |
| | | List<CMQManager.MQMsgConsumeResult> list = CMQManager.getInstance().consumeInvalidDeviceTokenQueue(16); |
| | | if (list != null) { |
| | | logger.info("清理无效token数量:" + list.size()); |
| | | for (CMQManager.MQMsgConsumeResult result : list) { |
| | |
| | | pushDeviceTokenManager.deleteByPrimaryKey(token.getId()); |
| | | } |
| | | } |
| | | CMQManager.getInstance().deleteMsg(CMQManager.PUSH_TOKEN_INVALID, result.getReceiptHandle()); |
| | | } |
| | | } |
| | | } catch (Exception e) { |