csoftware

1. bug之处 @Override public Future push(PushContext context) { if (!connection.getSessionContext().handshakeOk()) { logger.warn("connection is not handshake ok!"); return null; } PushMessage message = new PushMessage(context.getContext(), connection); message.addFlag(context.ackModel.flag); message.send(); logger.debug("

1. bug所在 @Override public void run() { queue.remove(sessionId); timeout(); } 2. bug的修复 @Override public void run() { RequestTask requestTask = queue.remove(sessionId); if (requestTask != null) { timeout(); } }

该项目没有可指定的解决版本