Get the connection listeners for a connection manager
@param cm The connection manager
@return The value
770461
List<ConnectionListener> getConnectionListeners(ConnectionManager cm)
   {
      if (cmToCl == null)
         return Collections.unmodifiableList(Collections.emptyList());

      List<ConnectionListener> l = cmToCl.get(cm);
      if (l == null)
         l = Collections.emptyList();
      
      return Collections.unmodifiableList(l);
   }
571906
private ClusterManagerService.Client getCMSClient()
    throws TTransportException {
    // Get the current configuration
    CoronaConf conf = new CoronaConf(getConf());
    return getCMSClient(conf);
  }
126266
private boolean shouldEnlist(ConnectionListener cl)
   {
      if (cmConfiguration.isEnlistment() && cl.getManagedConnection() instanceof LazyEnlistableManagedConnection)
         return false;

      return true;
   }
1059273
public static void addConnectionListener (@Nonnull final ConnectionListener aConnectionListener)
  {
    ValueEnforcer.notNull (aConnectionListener, "ConnectionListener");
    s_aRWLock.writeLocked ( () -> s_aConnectionListeners.add (aConnectionListener));
  }
669613
protected Set<ProbeListener> getProbeListeners(ProbeImpl probe) {
        Set<ProbeListener> listeners = enabledProbes.get(probe);
        if (listeners == null) {
            listeners = Collections.emptySet();
        }
        return listeners;
    }
284981
private static Set getListeners(final String busName) {

        final String methodName = "getListeners";
        if (TRACE.isEntryEnabled()) {
            SibTr.entry(TRACE, methodName, busName);
        }

        final Set listeners = new HashSet();

        synchronized (MESSAGING_ENGINE_LISTENERS) {

            // Get listeners for the particular bus
            final Set busListeners = (Set) MESSAGING_ENGINE_LISTENERS
                    .get(busName);
            if (busListeners != null) {
                listeners.addAll(busListeners);
            }

            // Get listeners for all busses
            final Set noBusListeners = (Set) MESSAGING_ENGINE_LISTENERS
                    .get(null);
            if (noBusListeners != null) {
                listeners.addAll(noBusListeners);
            }

        }

        if (TRACE.isEntryEnabled()) {
            SibTr.exit(TRACE, methodName, listeners);
        }
        return listeners;

    }
1188973
public <R> Connection<CL> getConnectionForOperation(BaseOperation<CL, R> baseOperation) {
	return selectionStrategy.getConnection(baseOperation, cpConfiguration.getMaxTimeoutWhenExhausted(),
		TimeUnit.MILLISECONDS);
    }
531235
void getBroadcast() {

        CmsCoreProvider.getService().getBroadcast(new AsyncCallback<List<CmsBroadcastMessage>>() {

            public void onFailure(Throwable caught) {

                // in case of a status code exception abort, indicates the session is no longer valid
                if ((caught instanceof StatusCodeException) && (((StatusCodeException)caught).getStatusCode() == 500)) {
                    CmsBroadcastTimer.abort();
                }
            }

            public void onSuccess(List<CmsBroadcastMessage> result) {

                if (result != null) {
                    for (CmsBroadcastMessage message : result) {
                        CmsNotification.get().sendAlert(Type.WARNING, createMessageHtml(message));
                    }
                }
            }
        });
    }
673162
public static synchronized BlockingCommandManager getInstanceFor(XMPPConnection connection) {
        BlockingCommandManager blockingCommandManager = INSTANCES.get(connection);

        if (blockingCommandManager == null) {
            blockingCommandManager = new BlockingCommandManager(connection);
            INSTANCES.put(connection, blockingCommandManager);
        }

        return blockingCommandManager;
    }
394477
private Connection getConnection(AlpineQueryManager aqm) {
        final JDOConnection jdoConnection = aqm.getPersistenceManager().getDataStoreConnection();
        if (jdoConnection != null) {
            if (jdoConnection.getNativeConnection() instanceof Connection) {
                return (Connection)jdoConnection.getNativeConnection();
            }
        }
        return null;
    }
1181630
private Connection getConnection(final ICommandLine cl) throws SQLException, InstantiationException, IllegalAccessException,
            ClassNotFoundException {
        DriverManager.registerDriver((Driver) Class.forName("oracle.jdbc.driver.OracleDriver").newInstance());

        LOG.debug(getContext(), "Connecting to " + cl.getOptionValue("db") + "@" + cl.getOptionValue("server"));

        return DriverManager.getConnection("jdbc:oracle:thin:@" + cl.getOptionValue("server") + ":" + cl.getOptionValue("port", "1521")
                + ":" + cl.getOptionValue("db"), cl.getOptionValue("username"), cl.getOptionValue("password"));
    }
218100
@SuppressWarnings("SynchronizationOnLocalVariableOrMethodParameter")
    public List<Connection> getConnections(final ConnectionMode connectionMode, final String dataSourceName, final int connectionSize, final TransactionType transactionType) throws SQLException {
        DataSource dataSource = dataSources.get(dataSourceName);
        if (1 == connectionSize) {
            return Collections.singletonList(createConnection(transactionType, dataSourceName, dataSource));
        }
        if (ConnectionMode.CONNECTION_STRICTLY == connectionMode) {
            return createConnections(transactionType, dataSourceName, dataSource, connectionSize);
        }
        synchronized (dataSource) {
            return createConnections(transactionType, dataSourceName, dataSource, connectionSize);
        }
    }
257171
public Connection getConnectionByUrl(String dbPoolUrl) throws SQLException {

        return CmsDriverManager.m_pools.get(dbPoolUrl).getConnection();
    }
892521
public static acolyte.jdbc.Connection connection(ConnectionHandler handler) {
        return connection(handler, (Properties) null);
    }
1240944
public void connect(Connection c) {

        schemaFilter = null;

        if (c == null) {
            return;
        }

        if (cConn != null) {
            try {
                cConn.close();
            } catch (SQLException e) {

                //  Added: (weconsultants@users)
                CommonSwing.errorMessage(e);
            }
        }

        cConn = c;

        // Added: (weconsultants@users) Need to barrow to get the table rowcounts
        rowConn = c;

        try {
            dMeta      = cConn.getMetaData();
            isOracle = (dMeta.getDatabaseProductName().indexOf("Oracle") >= 0);
            sStatement = cConn.createStatement();

            updateAutoCommitBox();

            // Workaround for EXTREME SLOWNESS getting this info from O.
            showIndexDetails = !isOracle;

            Driver driver = DriverManager.getDriver(dMeta.getURL());
            ConnectionSetting newSetting = new ConnectionSetting(
                dMeta.getDatabaseProductName(), driver.getClass().getName(),
                dMeta.getURL(),
                dMeta.getUserName().replaceAll("@localhost", ""), "");
            Hashtable settings =
                ConnectionDialogCommon.loadRecentConnectionSettings();

            ConnectionDialogCommon.addToRecentConnectionSettings(settings,
                    newSetting);
            ConnectionDialogSwing.setConnectionSetting(newSetting);
            refreshTree();
            clearResultPanel();

            if (fMain instanceof JApplet) {
                getAppletContext().showStatus(
                    "JDBC Connection established to a "
                    + dMeta.getDatabaseProductName() + " v. "
                    + dMeta.getDatabaseProductVersion() + " database as '"
                    + dMeta.getUserName() + "'.");
            }
        } catch (SQLException e) {

            //  Added: (weconsultants@users)
            CommonSwing.errorMessage(e);
        } catch (IOException e) {

            //  Added: (weconsultants@users)
            CommonSwing.errorMessage(e);
        } catch (Exception e) {
            CommonSwing.errorMessage(e);
        }
    }
1311975
public CatConnectionListenerGroup getCatConnectionListeners()
   {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "getCatConnectionListeners");
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "getCatConnectionListeners", catConnectionGroup);
      return catConnectionGroup;
   }
1219680
public java.util.List<Listener> getListeners() {
        if (listeners == null) {
            listeners = new com.amazonaws.internal.SdkInternalList<Listener>();
        }
        return listeners;
    }