wip

Author: injectives

driver/src/main/java/org/neo4j/driver/internal/cluster/RoutingTableRegistryImpl.java

@@ -80,16 +80,17 @@ public void remove( DatabaseName databaseName )
     @Override
     public void removeAged()
     {
-        routingTableHandlers.forEach( ( databaseName, handler ) ->
-                                      {
-                                          if ( handler.isRoutingTableAged() )
-                                          {
-                                              logger.info(
-                                                      "Routing table handler for database '%s' is removed because it has not been used for a long time. Routing table: %s",
-                                                      databaseName.description(), handler.routingTable() );
-                                              routingTableHandlers.remove( databaseName );
-                                          }
-                                      } );
+        routingTableHandlers.forEach(
+                ( databaseName, handler ) ->
+                {
+                    if ( handler.isRoutingTableAged() )
+                    {
+                        logger.info(
+                                "Routing table handler for database '%s' is removed because it has not been used for a long time. Routing table: %s",
+                                databaseName.description(), handler.routingTable() );
+                        routingTableHandlers.remove( databaseName );
+                    }
+                } );
     }
 
     @Override
@@ -106,12 +107,13 @@ public boolean contains( DatabaseName databaseName )
 
     private RoutingTableHandler getOrCreate( DatabaseName databaseName )
     {
-        return routingTableHandlers.computeIfAbsent( databaseName, name ->
-        {
-            RoutingTableHandler handler = factory.newInstance( name, this );
-            logger.debug( "Routing table handler for database '%s' is added.", databaseName.description() );
-            return handler;
-        } );
+        return routingTableHandlers.computeIfAbsent(
+                databaseName, name ->
+                {
+                    RoutingTableHandler handler = factory.newInstance( name, this );
+                    logger.debug( "Routing table handler for database '%s' is added.", databaseName.description() );
+                    return handler;
+                } );
     }
 
     static class RoutingTableHandlerFactory

driver/src/main/java/org/neo4j/driver/internal/cluster/loadbalancing/LoadBalancer.java

@@ -182,11 +182,12 @@ public RoutingTableRegistry getRoutingTableRegistry()
 
     private CompletionStage<Boolean> supportsMultiDb( BoltServerAddress address )
     {
-        return connectionPool.acquire( address ).thenCompose( conn ->
-                                                              {
-                                                                  boolean supportsMultiDatabase = supportsMultiDatabase( conn );
-                                                                  return conn.release().thenApply( ignored -> supportsMultiDatabase );
-                                                              } );
+        return connectionPool.acquire( address ).thenCompose(
+                conn ->
+                {
+                    boolean supportsMultiDatabase = supportsMultiDatabase( conn );
+                    return conn.release().thenApply( ignored -> supportsMultiDatabase );
+                } );
     }
 
     private CompletionStage<Connection> acquire( AccessMode mode, RoutingTable routingTable )