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

项目:OpenJSharp    文件: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;
}
项目: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;
}
项目: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;
}
项目:lookaside_java-1.8.0-openjdk    文件: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;
}
项目:infobip-open-jdk-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;
}
项目:jdk8u-dev-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;
}
项目:jdk7-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<MBeanServer>();
    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;
}
项目:openjdk-source-code-learn    文件: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<MBeanServer>();
    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;
}
项目:OLD-OpenJDK8    文件: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;
}
项目:openjdk-jdk7u-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<MBeanServer>();
    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;
}
项目:OpenJSharp    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:jdk8u-jdk    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:jdk8u-jdk    文件: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;
}
项目:jdk8u-jdk    文件: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);
        }
项目:jdk8u-jdk    文件: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);
        }
项目:jdk8u-jdk    文件:MBeanServerForwarderInvocationHandler.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);
    }
项目: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;
}
项目:openjdk-jdk10    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:openjdk-jdk10    文件: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;
}
项目:openjdk-jdk10    文件: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);
        }
项目:openjdk-jdk10    文件: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);
        }
项目:openjdk-jdk10    文件:MBeanServerForwarderInvocationHandler.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);
    }
项目:openjdk-jdk10    文件: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;
}
项目:openjdk9    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:openjdk9    文件: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;
}
项目:openjdk9    文件: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);
        }
项目:openjdk9    文件: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);
        }
项目:openjdk9    文件:MBeanServerForwarderInvocationHandler.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);
    }
项目:openjdk9    文件: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;
}
项目:Java8CN    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:jdk8u_jdk    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:jdk8u_jdk    文件: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;
}
项目:jdk8u_jdk    文件: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);
        }
项目:jdk8u_jdk    文件: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);
        }
项目:jdk8u_jdk    文件:MBeanServerForwarderInvocationHandler.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);
    }
项目: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;
}
项目:lookaside_java-1.8.0-openjdk    文件:RMIConnectorServer.java   
@Override
public synchronized
    void setMBeanServerForwarder(MBeanServerForwarder mbsf) {
    super.setMBeanServerForwarder(mbsf);
    if (rmiServerImpl != null)
        rmiServerImpl.setMBeanServer(getMBeanServer());
}
项目:lookaside_java-1.8.0-openjdk    文件: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;
}
项目:lookaside_java-1.8.0-openjdk    文件: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);
        }
项目:lookaside_java-1.8.0-openjdk    文件: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);
        }