remove duplicated release
@@ -1881,7 +1881,6 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
public int clearIncomingMessagesAndGetMessageNumber() {
int messagesNumber = incomingMessages.size();
- incomingMessages.forEach(Message::release);
clearIncomingMessages();
unAckedMessageTracker.clear();
return messagesNumber;
