[8.2.6][fix]修复空指针异常
This commit is contained in:
@@ -125,6 +125,15 @@ public class ReceivedAckManager {
|
|||||||
Iterator<ReceivedAck> iterator = queue.iterator();
|
Iterator<ReceivedAck> iterator = queue.iterator();
|
||||||
while (iterator.hasNext()) {
|
while (iterator.hasNext()) {
|
||||||
ReceivedAck ack = iterator.next();
|
ReceivedAck ack = iterator.next();
|
||||||
|
if (ack == null) {
|
||||||
|
iterator.remove();
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
MessageType messageType = ack.getMessageType();
|
||||||
|
if (messageType == null) {
|
||||||
|
iterator.remove();
|
||||||
|
continue;
|
||||||
|
}
|
||||||
long t = ack.getMessageType().timeoutMillis;
|
long t = ack.getMessageType().timeoutMillis;
|
||||||
if (t != 0L && time - ack.getSendTime() > t) {
|
if (t != 0L && time - ack.getSendTime() > t) {
|
||||||
//超时
|
//超时
|
||||||
|
|||||||
Reference in New Issue
Block a user