diff --git a/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java b/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java
index e95384b55..64cfbd13b 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java
@@ -327,6 +327,8 @@ public void run(Selectable selectable) {
                     // Ignore
                 }
             }
+            Transport transport = ((SelectableImpl)selectable).getTransport();
+            transport.close_tail();
         }
     };