public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

/**
 * Handle a connection reqUest.
 * @param context the JMX nio context.
 * @param request the connection request to handle.
 * @return the connection ID.
 * @throws Exception if any error occurs.
 */
private static String handleConnect(final JMXContext context, final JMXRequest request) throws Exception {
  final JMXAuthenticator authenticator = context.getChannels().getAuthenticator();
  if (authenticator != null) {
    final Subject subject = authenticator.authenticate(request.getParams()[0]);
    context.getChannels().setSubject(subject);
    final JMXAuthorizationChecker checker = context.getChannels().getAuhtorizationChecker();
    if (checker != null) checker.setSubject(subject);
  }
  return context.getConnectionID();
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public static void main(String[] args) throws Exception
{
   prepareUsersFile();

   // The address of the connector server
   JMXServiceURL url = new JMXServiceURL("rmi", "localhost", 0, "/jndi/jmx");

   // Specify the authenticator in the environment Map, using the
   // standard property JMXConnector.AUTHENTICATOR
   Map environment = new HashMap();
   JMXAuthenticator authenticator = new PasswordAuthenticator(new File(PASSWORD_FILE));
   environment.put(JMXConnectorServer.AUTHENTICATOR, authenticator);

   // Create and register the connector server
   JMXConnectorServer cntorServer = JMXConnectorServerFactory.newJMXConnectorServer(url, environment, null);
   ObjectName cntorServerName = ObjectName.getInstance(":service=" + JMXConnectorServer.class.getName() + ",protocol=" + url.getProtocol());
   MBeanServer server = MBeanServerFactory.createMBeanServer("remote.security.example");
   server.registerMBean(cntorServer, cntorServerName);

   // Setup the rmiregistry to bind in JNDI the RMIConnectorServer stub.
   NamingService naming = new NamingService();
   ObjectName namingName = ObjectName.getInstance(":service=" + NamingService.class.getName());
   server.registerMBean(naming, namingName);
   naming.start();

   // Start the connector server
   cntorServer.start();

   System.out.println("Server up and running");
}
 

public static void main(String[] args) throws Exception
{
   prepareUsersFile();

   // The address of the connector server
   JMXServiceURL url = new JMXServiceURL("rmi", "localhost", 0, "/jndi/jmx");

   // Specify the authenticator in the environment Map, using the
   // standard property JMXConnector.AUTHENTICATOR
   Map environment = new HashMap();
   JMXAuthenticator authenticator = new PasswordAuthenticator(new File(PASSWORD_FILE));
   environment.put(JMXConnectorServer.AUTHENTICATOR, authenticator);

   // Create and register the connector server
   JMXConnectorServer cntorServer = JMXConnectorServerFactory.newJMXConnectorServer(url, environment, null);
   ObjectName cntorServerName = ObjectName.getInstance(":service=" + JMXConnectorServer.class.getName() + ",protocol=" + url.getProtocol());
   MBeanServer server = MBeanServerFactory.createMBeanServer("remote.security.example");
   server.registerMBean(cntorServer, cntorServerName);

   // Setup the rmiregistry to bind in JNDI the RMIConnectorServer stub.
   NamingService naming = new NamingService();
   ObjectName namingName = ObjectName.getInstance(":service=" + NamingService.class.getName());
   server.registerMBean(naming, namingName);
   naming.start();

   // Setup the interception
   SubjectTrackingMBeanServer interceptor = new SubjectTrackingMBeanServer();
   cntorServer.setMBeanServerForwarder(interceptor);

   // Start the connector server
   cntorServer.start();

   System.out.println("Server up and running");
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

public Subject authenticate(Object credentials) {
    final JMXAuthenticator authenticator =
            new JMXPluggableAuthenticator(environment);
    final Subject subject = authenticator.authenticate(credentials);
    checkAccessFileEntries(subject);
    return subject;
}
 

private void start() {

        setContainer(new MBeanContainer(ManagementFactory.getPlatformMBeanServer()));
        int jmxPort = JMXManager.getPort();
        String jmxUrl = "/jndi/rmi://localhost:" + jmxPort + "/jmxrmi";
        Map<String, Object> env = new HashMap<>();
        if (JMXManager.isSecure()) {
            env.put("jmx.remote.authenticator", new JMXAuthenticator() {
                @Override
                public Subject authenticate(Object credentials) {
                    if (!(credentials instanceof String[])) {
                        if (credentials == null) {
                            throw new SecurityException("Credentials required");
                        }
                        throw new SecurityException("Credentials should be String[]");
                    }
                    final String[] aCredentials = (String[]) credentials;
                    if (aCredentials.length < 2) {
                        throw new SecurityException("Credentials should have at least two elements");
                    }
                    String username = aCredentials[0];
                    String password = aCredentials[1];

                    try {
                        AuthFactory.authenticate(username, password);
                    } catch (Exception ex) {
                        Log.error("Authentication failed for " + username);
                        throw new SecurityException();
                    }

                    if (AdminManager.getInstance().isUserAdmin(username, true)) {
                        return new Subject(true,
                                           Collections.singleton(new JMXPrincipal(username)),
                                           Collections.EMPTY_SET,
                                           Collections.EMPTY_SET);
                    } else {
                        Log.error("Authorization failed for " + username);
                        throw new SecurityException();
                    }
                }
            });
        }
        
        try {
            jmxServer = new ConnectorServer(new JMXServiceURL("rmi", null, jmxPort, jmxUrl), 
                    env, "org.eclipse.jetty.jmx:name=rmiconnectorserver");
            jmxServer.start();
        } catch (Exception e) {
            Log.error("Failed to start JMX connector", e);
        }
    }