private void abortActiveConnections ( final ExecutorService assassinExecutor ) { for ( PoolEntry poolEntry : connectionBag . values ( STATE_IN_USE ) ) { Connection connection = poolEntry . close ( ) ; try { connection . abort ( assassinExecutor ) ; } catch ( Throwable e ) { quietlyCloseConnection ( connection , "(connection aborted during shutdown)" ) ; } finally { connectionBag . remove ( poolEntry ) ; } } }
Attempt to abort or close active connections .