Fix ack timeout cause reconnect

[wolfstudy]

Signed-off-by: xiaolongran xiaolongran@tencent.com

Motivation

Most of this situation is caused by the timeout of sending the message. When the sending of the message times out, we will try to remove the object from the local pendingQueue, but after a period of time, the broker may push the message back, resulting in the connection reconnect occurs.

Follow Java SDK process logic:

            op = pendingMessages.peek();
            if (op == null) {
                if (log.isDebugEnabled()) {
                    log.debug("[{}] [{}] Got ack for timed out msg {} - {}", topic, producerName, sequenceId, highestSequenceId);
                }
                return;
            }

When a timeout occurs, we just need to drop the request instead of closing the connection.

Modifications

• Remove reconnection timeout when sendReceipt timeout.