Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2144#discussion_r195853177
--- Diff:
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/handler/ProtonHandler.java
---
@@ -209,15 +209,15 @@ public void flushBytes() {
lock.lock();
try {
while (true) {
- int pending = transport.pending();
+ ByteBuffer head = transport.head();
--- End diff --
nice catch! thanks!---
