类javax.management.remote.MBeanServerForwarder源码实例Demo

下面列出了怎么用javax.management.remote.MBeanServerForwarder的API类实例代码及写法,或者点击链接到github查看源代码。

/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码2 项目: dragonwell8_jdk   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码3 项目: TencentKona-8   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码4 项目: jdk8u_jdk   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码5 项目: jdk8u60   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码6 项目: JDKSourceCode1.8   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码7 项目: JPPF   文件: TestJMXServer.java
/**
 * Test without an MBeanServerForwarder.
 * @throws Exception if any error occurs
 */
@Test(timeout = 10000)
public void testNoMBeanForwarder() throws Exception {
  JMXServer server = null;
  try {
    JPPFConfiguration.set(JPPFProperties.MANAGEMENT_PORT, PORT)
      .set(JPPFProperties.JMX_REMOTE_PROTOCOL, JMXHelper.JPPF_JMX_PROTOCOL)
      .remove(JPPFProperties.MANAGEMENT_SERVER_FORWARDER);
    server = JMXServerFactory.createServer(JPPFConfiguration.getProperties(), "clientTest", false, JPPFProperties.MANAGEMENT_PORT);
    server.start(getClass().getClassLoader());
    final MBeanServerForwarder mbsf = server.getMBeanServerForwarder();
    assertNull(mbsf);
  } finally {
    if (server != null) {
      try {
        server.stop();
      } catch (final Exception e) {
        e.printStackTrace();
      }
    }
  }
}
 
源代码8 项目: openjdk-jdk8u   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码9 项目: openjdk-8   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
源代码10 项目: jdk8u-jdk   文件: CommunicatorServer.java
/**
 * Set the <code>MBeanServer</code> object to which incoming
 * requests are sent.  This must be either the MBean server in
 * which this connector is registered, or an
 * <code>MBeanServerForwarder</code> leading to that server.  An
 * <code>MBeanServerForwarder</code> <code>mbsf</code> leads to an
 * MBean server <code>mbs</code> if
 * <code>mbsf.getMBeanServer()</code> is either <code>mbs</code>
 * or an <code>MBeanServerForwarder</code> leading to
 * <code>mbs</code>.
 *
 * @exception IllegalArgumentException if <code>newMBS</code> is neither
 * the MBean server in which this connector is registered nor an
 * <code>MBeanServerForwarder</code> leading to that server.
 *
 * @exception IllegalStateException This method has been invoked
 * while the communicator was ONLINE or STARTING.
 */
public synchronized void setMBeanServer(MBeanServer newMBS)
        throws IllegalArgumentException, IllegalStateException {
    synchronized (stateLock) {
        if (state == ONLINE || state == STARTING)
            throw new IllegalStateException("Stop server before " +
                                            "carrying out this operation");
    }
    final String error =
        "MBeanServer argument must be MBean server where this " +
        "server is registered, or an MBeanServerForwarder " +
        "leading to that server";
    Vector<MBeanServer> seenMBS = new Vector<>();
    for (MBeanServer mbs = newMBS;
         mbs != bottomMBS;
         mbs = ((MBeanServerForwarder) mbs).getMBeanServer()) {
        if (!(mbs instanceof MBeanServerForwarder))
            throw new IllegalArgumentException(error);
        if (seenMBS.contains(mbs))
            throw new IllegalArgumentException("MBeanServerForwarder " +
                                               "loop");
        seenMBS.addElement(mbs);
    }
    topMBS = newMBS;
}
 
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
 
源代码12 项目: dragonwell8_jdk   文件: RMIConnectorServer.java
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
 
public MBeanServer newMBeanServer(
        String defaultDomain,
        MBeanServer outer,
        MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
            MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
            inner.newMBeanServer(defaultDomain,
            (outer == null ? mbsf : outer),
            delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler =
                    new MBeanServerForwarderInvocationHandler();

            final Class[] interfaces =
                    new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                    MBeanServerForwarder.class.getClassLoader(),
                    interfaces,
                    handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler = new MBSFInvocationHandler();

            final Class[] interfaces =
                new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                                 MBeanServerForwarder.class.getClassLoader(),
                                 interfaces,
                                 handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
public static MBeanServerForwarder newProxyInstance() {

        final InvocationHandler handler =
            new MBeanServerForwarderInvocationHandler();

        final Class[] interfaces =
            new Class[] {MBeanServerForwarder.class};

        Object proxy = Proxy.newProxyInstance(
                             MBeanServerForwarder.class.getClassLoader(),
                             interfaces,
                             handler);

        return MBeanServerForwarder.class.cast(proxy);
    }
 
public static MBeanServerForwarder newProxyInstance() {

        final InvocationHandler handler =
            new MBeanServerForwarderInvocationHandler();

        final Class[] interfaces =
            new Class[] {MBeanServerForwarder.class};

        Object proxy = Proxy.newProxyInstance(
                             MBeanServerForwarder.class.getClassLoader(),
                             interfaces,
                             handler);

        return MBeanServerForwarder.class.cast(proxy);
    }
 
源代码18 项目: dragonwell8_jdk   文件: MBeanServerBuilderImpl.java
public MBeanServer newMBeanServer(String defaultDomain,
                                  MBeanServer outer,
                                  MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
        MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
        inner.newMBeanServer(defaultDomain,
                             (outer == null ? mbsf : outer),
                             delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
public MBeanServer newMBeanServer(
        String defaultDomain,
        MBeanServer outer,
        MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
            MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
            inner.newMBeanServer(defaultDomain,
            (outer == null ? mbsf : outer),
            delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler =
                    new MBeanServerForwarderInvocationHandler();

            final Class[] interfaces =
                    new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                    MBeanServerForwarder.class.getClassLoader(),
                    interfaces,
                    handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
源代码21 项目: TencentKona-8   文件: MBSFPreStartPostStartTest.java
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler = new MBSFInvocationHandler();

            final Class[] interfaces =
                new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                                 MBeanServerForwarder.class.getClassLoader(),
                                 interfaces,
                                 handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
源代码22 项目: openjdk-8-source   文件: MBeanServerBuilderImpl.java
public MBeanServer newMBeanServer(String defaultDomain,
                                  MBeanServer outer,
                                  MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
        MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
        inner.newMBeanServer(defaultDomain,
                             (outer == null ? mbsf : outer),
                             delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
源代码23 项目: jdk8u_jdk   文件: MBeanServerBuilderImpl.java
public MBeanServer newMBeanServer(String defaultDomain,
                                  MBeanServer outer,
                                  MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
        MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
        inner.newMBeanServer(defaultDomain,
                             (outer == null ? mbsf : outer),
                             delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
源代码24 项目: TencentKona-8   文件: MBeanServerBuilderImpl.java
public MBeanServer newMBeanServer(String defaultDomain,
                                  MBeanServer outer,
                                  MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
        MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
        inner.newMBeanServer(defaultDomain,
                             (outer == null ? mbsf : outer),
                             delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
public MBeanServer newMBeanServer(
        String defaultDomain,
        MBeanServer outer,
        MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
            MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
            inner.newMBeanServer(defaultDomain,
            (outer == null ? mbsf : outer),
            delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler =
                    new MBeanServerForwarderInvocationHandler();

            final Class[] interfaces =
                    new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                    MBeanServerForwarder.class.getClassLoader(),
                    interfaces,
                    handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
源代码27 项目: jdk8u60   文件: RMIConnectorServer.java
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
 
源代码28 项目: jdk8u60   文件: MBeanServerMXBeanUnsupportedTest.java
public MBeanServer newMBeanServer(
        String defaultDomain,
        MBeanServer outer,
        MBeanServerDelegate delegate) {
    final MBeanServerForwarder mbsf =
            MBeanServerForwarderInvocationHandler.newProxyInstance();

    final MBeanServer innerMBeanServer =
            inner.newMBeanServer(defaultDomain,
            (outer == null ? mbsf : outer),
            delegate);

    mbsf.setMBeanServer(innerMBeanServer);
    return mbsf;
}
 
源代码29 项目: jdk8u60   文件: MBeanServerMXBeanUnsupportedTest.java
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler =
                    new MBeanServerForwarderInvocationHandler();

            final Class[] interfaces =
                    new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                    MBeanServerForwarder.class.getClassLoader(),
                    interfaces,
                    handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
源代码30 项目: jdk8u60   文件: MBSFPreStartPostStartTest.java
public static MBeanServerForwarder newProxyInstance() {

            final InvocationHandler handler = new MBSFInvocationHandler();

            final Class[] interfaces =
                new Class[] {MBeanServerForwarder.class};

            Object proxy = Proxy.newProxyInstance(
                                 MBeanServerForwarder.class.getClassLoader(),
                                 interfaces,
                                 handler);

            return MBeanServerForwarder.class.cast(proxy);
        }
 
 类所在包
 类方法
 同包方法