wip

Author: injectives

driver/src/main/java/org/neo4j/driver/exceptions/ConnectionReadTimeoutException.java

@@ -21,7 +21,7 @@
 /**
  * Indicates that read timed out due to it taking longer than the server-supplied timeout value via the {@code connection.recv_timeout_seconds} configuration
  * hint. The server might provide this value to clients to let them know when a given connection may be considered broken if client does not get any
- * communication from the server within the specified timeout period.
+ * communication from the server within the specified timeout period. This results in the server being removed from the routing table.
  */
 public class ConnectionReadTimeoutException extends ServiceUnavailableException
 {

driver/src/main/java/org/neo4j/driver/internal/async/inbound/ConnectionReadTimeoutHandler.java

@@ -39,8 +39,8 @@ protected void readTimedOut( ChannelHandlerContext ctx )
     {
         if ( !triggered )
         {
-            // channel state management is handled in response handlers
             ctx.fireExceptionCaught( ConnectionReadTimeoutException.INSTANCE );
+            ctx.close();
             triggered = true;
         }
     }

driver/src/test/java/org/neo4j/driver/internal/async/inbound/ConnectionReadTimeoutHandlerTest.java

@@ -37,12 +37,13 @@ public class ConnectionReadTimeoutHandlerTest
     ChannelHandlerContext context = mock( ChannelHandlerContext.class );
 
     @Test
-    void shouldFireConnectionReadTimeoutExceptionOnReadTimeOutOnce()
+    void shouldFireConnectionReadTimeoutExceptionAndCloseChannelOnReadTimeOutOnce()
     {
         // WHEN
         IntStream.range( 0, 10 ).forEach( i -> handler.readTimedOut( context ) );
 
         // THEN
         then( context ).should( times( 1 ) ).fireExceptionCaught( any( ConnectionReadTimeoutException.class ) );
+        then( context ).should( times( 1 ) ).close();
     }
 }