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);
         }
      }
   }
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.

@param assassinExecutor the ExecutorService to pass to Connection.abort()