| | |
| | | this.connectionList = new CopyOnWriteArrayList<>(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public ConfigChangeResult applyConfigurationChange( |
| | | JMXConnectionHandlerCfg config) { |
| | | final ConfigChangeResult ccr = new ConfigChangeResult(); |
| | | |
| | | // Determine whether or not the RMI connection needs restarting. |
| | | // Determine whether the RMI connection needs restarting. |
| | | boolean rmiConnectorRestart = false; |
| | | boolean portChanged = false; |
| | | |
| | |
| | | return o1 != null && !o1.equals(o2); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void finalizeConnectionHandler(LocalizableMessage finalizeReason) { |
| | | // Make sure that we don't get notified of any more changes. |
| | |
| | | return rmiConnector; |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getShutdownListenerName() { |
| | | return connectionHandlerName; |
| | |
| | | return currentConfig.getSSLCertNickname(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void initializeConnectionHandler(ServerContext serverContext, JMXConnectionHandlerCfg config) |
| | | throws ConfigException, InitializationException |
| | |
| | | config.addJMXChangeListener(this); |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getConnectionHandlerName() { |
| | | return connectionHandlerName; |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getProtocol() { |
| | | return protocol; |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public Collection<HostPort> getListeners() { |
| | | return listeners; |
| | | } |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public boolean isConfigurationAcceptable(ConnectionHandlerCfg configuration, |
| | | List<LocalizableMessage> unacceptableReasons) |
| | |
| | | new InetSocketAddress(newPort).getAddress(), newPort, true)) { |
| | | throw new IOException(ERR_CONNHANDLER_ADDRESS_INUSE.get().toString()); |
| | | } |
| | | return true; |
| | | } catch (Exception e) { |
| | | LocalizableMessage message = ERR_CONNHANDLER_CANNOT_BIND.get("JMX", configDN, |
| | | WILDCARD_ADDRESS, newPort, getExceptionMessage(e)); |
| | | unacceptableReasons.add(message); |
| | | return false; |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public boolean isConfigurationChangeAcceptable( |
| | | JMXConnectionHandlerCfg config, |
| | |
| | | |
| | | |
| | | /** |
| | | * Determines whether or not clients are allowed to connect over JMX |
| | | * using SSL. |
| | | * Determines whether clients are allowed to connect over JMX using SSL. |
| | | * |
| | | * @return Returns {@code true} if clients are allowed to |
| | | * connect over JMX using SSL. |
| | |
| | | return currentConfig.isUseSSL(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void processServerShutdown(LocalizableMessage reason) { |
| | | // We should also close the RMI registry. |
| | |
| | | connectionList.remove(connection); |
| | | } |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void run() { |
| | | try |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void toString(StringBuilder buffer) { |
| | | buffer.append(connectionHandlerName); |