@@ -287,7 +287,7 @@ protected void alterTableName(String tableName, String newTableName)
287287 }
288288
289289 protected void closeConnections () {
290- Map <Thread , Connection > connectionsMap = _companyConnectionsMap .get (
290+ Map <Thread , Connection > connectionsMap = _connectionsMaps .get (
291291 CompanyThreadLocal .getCompanyId ());
292292
293293 _closeConnections (connectionsMap );
@@ -590,7 +590,7 @@ private int _getConnectionsCount() {
590590 int connectionsCount = 0 ;
591591
592592 for (Map <Thread , Connection > connectionsMap :
593- _companyConnectionsMap .values ()) {
593+ _connectionsMaps .values ()) {
594594
595595 connectionsCount += connectionsMap .size ();
596596 }
@@ -734,7 +734,7 @@ private <T> void _processConcurrently(
734734
735735 private static final Log _log = LogFactoryUtil .getLog (BaseDBProcess .class );
736736
737- private final Map <Long , Map <Thread , Connection >> _companyConnectionsMap =
737+ private final Map <Long , Map <Thread , Connection >> _connectionsMaps =
738738 new ConcurrentHashMap <>();
739739
740740 private class ConnectionThreadProxyInvocationHandler
@@ -749,7 +749,7 @@ public Object invoke(Object proxy, Method method, Object[] args)
749749 if (methodName .equals ("close" )) {
750750 if (_getConnectionsCount () > 0 ) {
751751 for (Map <Thread , Connection > connectionsMap :
752- _companyConnectionsMap .values ()) {
752+ _connectionsMaps .values ()) {
753753
754754 _closeConnections (connectionsMap );
755755 }
@@ -759,7 +759,7 @@ public Object invoke(Object proxy, Method method, Object[] args)
759759 }
760760
761761 Map <Thread , Connection > connectionsMap =
762- _companyConnectionsMap .computeIfAbsent (
762+ _connectionsMaps .computeIfAbsent (
763763 CompanyThreadLocal .getCompanyId (),
764764 key -> new ConcurrentHashMap <>());
765765
0 commit comments