8173607: JMX RMI connector should be in its own module
Summary: The JMX RMI connector is moved to a new java.management.rmi module.
Reviewed-by: mchung, erikj
/*
* Copyright (c) 2005, 2015, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
/*
* @test
* @bug 6175517 6304996
* @summary General MXBean test: createMBean, registerMBean, immutableInfo,
* interfaceClassName, openType, originalType, StandardMBean,
* StandardEmitterMBean.
* @author Luis-Miguel Alventosa
* @modules java.management
* @run clean MiscTest
* @run build MiscTest
* @run main MiscTest
*/
import java.io.*;
import java.lang.management.*;
import javax.management.*;
import javax.management.openmbean.*;
public class MiscTest {
private static final MBeanNotificationInfo notifs[] =
new MBeanNotificationInfo[] {
new MBeanNotificationInfo(
new String[] {AttributeChangeNotification.ATTRIBUTE_CHANGE},
AttributeChangeNotification.class.getName(),
"This notification is emitted when the reset() method is called.")
};
private static Class<?> testClasses[] = {
Test11.class, Test12.class,
Test21.class, Test22.class,
Test31.class, Test32.class,
Test33.class, Test34.class,
Test41.class, Test42.class,
Test43.class, Test44.class,
};
private static Class<?> testIntfs[] = {
Test11MBean.class, Test12MBean.class,
Test21MXBean.class, Test22MXBean.class,
Test31SMB.class, Test32SMB.class,
Test33SMB.class, Test34SMB.class,
Test41SMX.class, Test42SMX.class,
Test43SMX.class, Test44SMX.class,
};
public interface SuperInterface {
public String getState();
public void setState(String s);
public int getNbChanges();
public void reset();
public void close(boolean force);
public MemoryUsage getMemoryUsage();
}
public static class BaseTest {
public String getState() {
return state;
}
public void setState(String s) {
state = s;
nbChanges++;
}
public int getNbChanges() {
return nbChanges;
}
public void reset() {
state = "initial state";
nbChanges = 0;
nbResets++;
}
public String getName() {
return "name";
}
public void setName(String s) {
}
public void close(boolean force) {
}
public MemoryUsage getMemoryUsage() {
return new MemoryUsage(10, 20, 30, 40);
}
public int getNbResets() {
return nbResets;
}
private String state = "initial state";
private int nbChanges = 0;
private int nbResets = 0;
}
public static class BaseEmitterTest
extends NotificationBroadcasterSupport {
public String getState() {
return state;
}
public void setState(String s) {
state = s;
nbChanges++;
}
public int getNbChanges() {
return nbChanges;
}
public void reset() {
state = "initial state";
nbChanges = 0;
nbResets++;
}
public String getName() {
return "name";
}
public void setName(String s) {
}
public void close(boolean force) {
}
public MemoryUsage getMemoryUsage() {
return new MemoryUsage(10, 20, 30, 40);
}
public int getNbResets() {
return nbResets;
}
public MBeanNotificationInfo[] getNotificationInfo() {
return notifs;
}
private String state = "initial state";
private int nbChanges = 0;
private int nbResets = 0;
}
public static interface Test11MBean extends SuperInterface {
}
public static interface Test12MBean extends SuperInterface {
}
public static interface Test21MXBean extends SuperInterface {
}
public static interface Test22MXBean extends SuperInterface {
}
public static interface Test31SMB extends SuperInterface {
}
public static interface Test32SMB extends SuperInterface {
}
public static interface Test33SMB extends SuperInterface {
}
public static interface Test34SMB extends SuperInterface {
}
public static interface Test41SMX extends SuperInterface {
}
public static interface Test42SMX extends SuperInterface {
}
public static interface Test43SMX extends SuperInterface {
}
public static interface Test44SMX extends SuperInterface {
}
public static class Test11 extends BaseTest
implements Test11MBean {
}
public static class Test12 extends BaseEmitterTest
implements Test12MBean {
}
public static class Test21 extends BaseTest
implements Test21MXBean {
}
public static class Test22 extends BaseEmitterTest
implements Test22MXBean {
}
public static class Test31 extends BaseTest
implements Test31SMB {
}
public static class Test32 extends BaseEmitterTest
implements Test32SMB {
}
public static class Test33 extends StandardMBean
implements Test33SMB {
public Test33() {
super(Test33SMB.class, false);
}
public String getState() {
return state;
}
public void setState(String s) {
state = s;
nbChanges++;
}
public int getNbChanges() {
return nbChanges;
}
public void reset() {
state = "initial state";
nbChanges = 0;
nbResets++;
}
public String getName() {
return "name";
}
public void setName(String s) {
}
public void close(boolean force) {
}
public MemoryUsage getMemoryUsage() {
return new MemoryUsage(10, 20, 30, 40);
}
public int getNbResets() {
return nbResets;
}
private String state = "initial state";
private int nbChanges = 0;
private int nbResets = 0;
}
public static class Test34 extends StandardEmitterMBean
implements Test34SMB {
public Test34() {
super(Test34SMB.class, false,
new NotificationBroadcasterSupport(notifs));
}
public String getState() {
return state;
}
public void setState(String s) {
state = s;
nbChanges++;
}
public int getNbChanges() {
return nbChanges;
}
public void reset() {
state = "initial state";
nbChanges = 0;
nbResets++;
}
public String getName() {
return "name";
}
public void setName(String s) {
}
public void close(boolean force) {
}
public MemoryUsage getMemoryUsage() {
return new MemoryUsage(10, 20, 30, 40);
}
public int getNbResets() {
return nbResets;
}
private String state = "initial state";
private int nbChanges = 0;
private int nbResets = 0;
}
public static class Test41 extends BaseTest
implements Test41SMX {
}
public static class Test42 extends BaseEmitterTest
implements Test42SMX {
}
public static class Test43 extends StandardMBean
implements Test43SMX {
public Test43() {
super(Test43SMX.class, true);
}
public String getState() {
return state;
}
public void setState(String s) {
state = s;
nbChanges++;
}
public int getNbChanges() {
return nbChanges;
}
public void reset() {
state = "initial state";
nbChanges = 0;
nbResets++;
}
public String getName() {
return "name";
}
public void setName(String s) {
}
public void close(boolean force) {
}
public MemoryUsage getMemoryUsage() {
return new MemoryUsage(10, 20, 30, 40);
}
public int getNbResets() {
return nbResets;
}
private String state = "initial state";
private int nbChanges = 0;
private int nbResets = 0;
}
public static class Test44 extends StandardEmitterMBean
implements Test44SMX {
public Test44() {
super(Test44SMX.class, true,
new NotificationBroadcasterSupport(notifs));
}
public String getState() {
return state;
}
public void setState(String s) {
state = s;
nbChanges++;
}
public int getNbChanges() {
return nbChanges;
}
public void reset() {
state = "initial state";
nbChanges = 0;
nbResets++;
}
public String getName() {
return "name";
}
public void setName(String s) {
}
public void close(boolean force) {
}
public MemoryUsage getMemoryUsage() {
return new MemoryUsage(10, 20, 30, 40);
}
public int getNbResets() {
return nbResets;
}
private String state = "initial state";
private int nbChanges = 0;
private int nbResets = 0;
}
public static void main(String[] args) throws Exception {
// Instantiate the MBean server
//
echo("\n>>> Create the MBean server");
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
// Get default domain
//
echo("\n>>> Get the MBean server's default domain");
String domain = mbs.getDefaultDomain();
echo("\tDefault Domain = " + domain);
for (int i = 0; i < testClasses.length; i++) {
// Create and register the Test MBean
//
String cn = testClasses[i].getName();
String ons = domain + ":type=" + cn;
echo("\n>>> Create the " + cn +
" MBean within the MBeanServer");
echo("\tObjectName = " + ons);
ObjectName on = ObjectName.getInstance(ons);
if (testClasses[i] == Test31.class ||
testClasses[i] == Test41.class) {
StandardMBean s = new StandardMBean(
testClasses[i].newInstance(),
(Class) testIntfs[i],
testClasses[i] == Test41.class);
mbs.registerMBean(s, on);
} else if (testClasses[i] == Test32.class ||
testClasses[i] == Test42.class) {
Object o = testClasses[i].newInstance();
StandardEmitterMBean s = new StandardEmitterMBean(
o,
(Class) testIntfs[i],
testClasses[i] == Test42.class,
(NotificationEmitter) o);
mbs.registerMBean(s, on);
} else {
mbs.createMBean(cn, on);
}
// Check notifs
//
MBeanInfo mbi = mbs.getMBeanInfo(on);
MBeanNotificationInfo mbni[] = mbi.getNotifications();
if (i % 2 == 0) {
if (mbni.length != 0) {
throw new IllegalArgumentException(
"Should not be a NotificationEmitter");
}
} else {
if (mbni.length != 1) {
throw new IllegalArgumentException(
"Should not a NotificationEmitter with one notification");
}
}
// Manage the Test MBean
//
manageMBean(mbs, on, cn);
}
}
private static void manageMBean(MBeanServer mbs,
ObjectName on,
String cn)
throws Exception {
echo("\n>>> Manage the " + cn +
" MBean using its attributes ");
echo(" and operations exposed for management");
// Get attribute values
printAttributes(mbs, on);
// Change State attribute
echo("\n Setting State attribute to value \"new state\"...");
Attribute stateAttribute = new Attribute("State","new state");
mbs.setAttribute(on, stateAttribute);
// Get attribute values
printAttributes(mbs, on);
// Invoking reset operation
echo("\n Invoking reset operation...");
mbs.invoke(on, "reset", null, null);
// Invoking close operation
echo("\n Invoking close operation...");
String type = on.getKeyProperty("type");
String signature[] = {"boolean"};
mbs.invoke(on, "close", new Object[] {true}, signature);
// Get attribute values
printAttributes(mbs, on);
// Create proxy
if (type.equals(Test11.class.getName())) {
Test11MBean p = JMX.newMBeanProxy(mbs,
on,
Test11MBean.class);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test11MBean.class.getName());
} else if (type.equals(Test12.class.getName())) {
Test12MBean p = JMX.newMBeanProxy(mbs,
on,
Test12MBean.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "false", Test12MBean.class.getName());
} else if (type.equals(Test21.class.getName())) {
Test21MXBean p = JMX.newMXBeanProxy(mbs,
on,
Test21MXBean.class);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test21MXBean.class.getName());
} else if (type.equals(Test22.class.getName())) {
Test22MXBean p = JMX.newMXBeanProxy(mbs,
on,
Test22MXBean.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test22MXBean.class.getName());
} else if (type.equals(Test31.class.getName())) {
Test31SMB p = JMX.newMBeanProxy(mbs,
on,
Test31SMB.class);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test31SMB.class.getName());
} else if (type.equals(Test32.class.getName())) {
Test32SMB p = JMX.newMBeanProxy(mbs,
on,
Test32SMB.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test32SMB.class.getName());
} else if (type.equals(Test33.class.getName())) {
Test33SMB p = JMX.newMBeanProxy(mbs,
on,
Test33SMB.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test33SMB.class.getName());
} else if (type.equals(Test34.class.getName())) {
Test34SMB p = JMX.newMBeanProxy(mbs,
on,
Test34SMB.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test34SMB.class.getName());
} else if (type.equals(Test41.class.getName())) {
Test41SMX p = JMX.newMXBeanProxy(mbs,
on,
Test41SMX.class);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test41SMX.class.getName());
} else if (type.equals(Test42.class.getName())) {
Test42SMX p = JMX.newMXBeanProxy(mbs,
on,
Test42SMX.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test42SMX.class.getName());
} else if (type.equals(Test43.class.getName())) {
Test43SMX p = JMX.newMXBeanProxy(mbs,
on,
Test43SMX.class);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test43SMX.class.getName());
} else if (type.equals(Test44.class.getName())) {
Test44SMX p = JMX.newMXBeanProxy(mbs,
on,
Test44SMX.class,
true);
// Get attribute values
echo("\n Getting attribute values through proxies:");
echo("\tState = \"" + p.getState() + "\"");
echo("\tNbChanges = " + p.getNbChanges());
echo("\tMemoryUsage = " + p.getMemoryUsage());
checkDescriptor(mbs, on, "true", Test44SMX.class.getName());
} else {
throw new IllegalArgumentException("Invalid MBean type");
}
}
private static void printAttributes(MBeanServer mbs,
ObjectName on)
throws Exception {
echo("\n Getting attribute values:");
String state = (String) mbs.getAttribute(on, "State");
Integer nbChanges = (Integer) mbs.getAttribute(on,"NbChanges");
echo("\tState = \"" + state + "\"");
echo("\tNbChanges = " + nbChanges);
String type = on.getKeyProperty("type");
if (type.indexOf("Test2") != -1 || type.indexOf("Test4") != -1) {
CompositeData memoryUsage =
(CompositeData) mbs.getAttribute(on, "MemoryUsage");
echo("\tMemoryUsage = " + memoryUsage);
} else {
MemoryUsage memoryUsage =
(MemoryUsage) mbs.getAttribute(on, "MemoryUsage");
echo("\tMemoryUsage = " + memoryUsage);
}
}
public static void checkDescriptor(MBeanServer mbs,
ObjectName on,
String immutable,
String intf)
throws Exception {
MBeanInfo mbi = mbs.getMBeanInfo(on);
Descriptor d = mbi.getDescriptor();
if (d == null || d.getFieldNames().length == 0)
throw new IllegalArgumentException("Empty descriptor");
if (!d.getFieldValue("immutableInfo").equals(immutable)) {
final String msg =
"Bad descriptor: expected immutableInfo=" + immutable + ": " + d;
throw new IllegalArgumentException(msg);
}
if (!d.getFieldValue("interfaceClassName").equals(intf)) {
final String msg =
"Bad descriptor: expected interfaceClassName=" + intf + ": " + d;
throw new IllegalArgumentException(msg);
}
if (intf.indexOf("MX") != -1) {
MBeanAttributeInfo attrs[] = mbi.getAttributes();
if (attrs == null || attrs.length == 0)
throw new IllegalArgumentException("No attributes");
boolean nbChangesFound = false;
for (MBeanAttributeInfo attr : attrs) {
if (attr.getName().equals("NbChanges")) {
nbChangesFound = true;
Descriptor ad = attr.getDescriptor();
OpenType<?> opty = (OpenType<?>)
ad.getFieldValue("openType");
if (!opty.equals(SimpleType.INTEGER)) {
throw new IllegalArgumentException("Open type should " +
"be INTEGER: " + opty);
}
String orty =
(String) ad.getFieldValue("originalType");
if (!orty.equals(Integer.TYPE.getName())) {
throw new IllegalArgumentException("Orig type should " +
"be int: " + orty);
}
}
}
if (!nbChangesFound)
throw new IllegalArgumentException("Did not find NbChanges");
}
}
private static void echo(String msg) {
System.out.println(msg);
}
}