44 import org.openjdk.jmc.rjmx.ConnectionDescriptorBuilder;
45 import org.openjdk.jmc.rjmx.ConnectionToolkit;
46 import org.openjdk.jmc.rjmx.IConnectionDescriptor;
47 import org.openjdk.jmc.rjmx.IConnectionHandle;
48 import org.openjdk.jmc.rjmx.IServerHandle;
49 import org.openjdk.jmc.rjmx.internal.JMXConnectionDescriptor;
50 import org.openjdk.jmc.rjmx.subscription.IMRISubscription;
51 import org.openjdk.jmc.rjmx.subscription.IMRIValueListener;
52 import org.openjdk.jmc.rjmx.subscription.ISubscriptionService;
53 import org.openjdk.jmc.rjmx.subscription.MRI;
54 import org.openjdk.jmc.rjmx.subscription.MRI.Type;
55 import org.openjdk.jmc.rjmx.subscription.MRIValueEvent;
56 import org.openjdk.jmc.rjmx.subscription.PolicyFactory;
57
58 /**
59 * Basic tests for the new cleaned up RJMX API.
60 */
61 public class BasicCommunicationTest extends ServerHandleTestCase {
62 final static int DEFAULT_PORT = 0;
63 final static String DEFAULT_HOST = "localhost".intern(); //$NON-NLS-1$
64 final static String ALTERNATIVE_HOST = "127.0.0.1".intern(); //$NON-NLS-1$
65
66 /**
67 * Attempts creating a {@link JMXConnectionDescriptor} with a bunch of options.
68 */
69 @Test
70 public void testCreateJMXDescriptor() throws IOException {
71 IConnectionDescriptor descriptor = LocalRJMXTestToolkit.createDefaultDescriptor();
72 JMXServiceURL url = descriptor.createJMXServiceURL();
73 assertEquals(DEFAULT_HOST, ConnectionToolkit.getHostName(url));
74 assertEquals(DEFAULT_PORT, ConnectionToolkit.getPort(url));
75 }
76
77 @Test
78 public void testIConnectionHandle() throws Exception {
79 IConnectionHandle handle = getDefaultServer().connect("Test"); //$NON-NLS-1$
80 MRI descriptor = new MRI(Type.ATTRIBUTE, "java.lang:type=Threading", //$NON-NLS-1$
81 "ThreadCount"); //$NON-NLS-1$
82 MBeanServerConnection connection = handle.getServiceOrThrow(MBeanServerConnection.class);
83 assertBetween(1L, 1000L,
84 ((Number) connection.getAttribute(descriptor.getObjectName(), descriptor.getDataPath())).longValue());
|
44 import org.openjdk.jmc.rjmx.ConnectionDescriptorBuilder;
45 import org.openjdk.jmc.rjmx.ConnectionToolkit;
46 import org.openjdk.jmc.rjmx.IConnectionDescriptor;
47 import org.openjdk.jmc.rjmx.IConnectionHandle;
48 import org.openjdk.jmc.rjmx.IServerHandle;
49 import org.openjdk.jmc.rjmx.internal.JMXConnectionDescriptor;
50 import org.openjdk.jmc.rjmx.subscription.IMRISubscription;
51 import org.openjdk.jmc.rjmx.subscription.IMRIValueListener;
52 import org.openjdk.jmc.rjmx.subscription.ISubscriptionService;
53 import org.openjdk.jmc.rjmx.subscription.MRI;
54 import org.openjdk.jmc.rjmx.subscription.MRI.Type;
55 import org.openjdk.jmc.rjmx.subscription.MRIValueEvent;
56 import org.openjdk.jmc.rjmx.subscription.PolicyFactory;
57
58 /**
59 * Basic tests for the new cleaned up RJMX API.
60 */
61 public class BasicCommunicationTest extends ServerHandleTestCase {
62 final static int DEFAULT_PORT = 0;
63 final static String DEFAULT_HOST = "localhost".intern(); //$NON-NLS-1$
64 final static String ALTERNATIVE_HOST = "127.1.0.1".intern(); //$NON-NLS-1$
65
66 /**
67 * Attempts creating a {@link JMXConnectionDescriptor} with a bunch of options.
68 */
69 @Test
70 public void testCreateJMXDescriptor() throws IOException {
71 IConnectionDescriptor descriptor = LocalRJMXTestToolkit.createDefaultDescriptor();
72 JMXServiceURL url = descriptor.createJMXServiceURL();
73 assertEquals(DEFAULT_HOST, ConnectionToolkit.getHostName(url));
74 assertEquals(DEFAULT_PORT, ConnectionToolkit.getPort(url));
75 }
76
77 @Test
78 public void testIConnectionHandle() throws Exception {
79 IConnectionHandle handle = getDefaultServer().connect("Test"); //$NON-NLS-1$
80 MRI descriptor = new MRI(Type.ATTRIBUTE, "java.lang:type=Threading", //$NON-NLS-1$
81 "ThreadCount"); //$NON-NLS-1$
82 MBeanServerConnection connection = handle.getServiceOrThrow(MBeanServerConnection.class);
83 assertBetween(1L, 1000L,
84 ((Number) connection.getAttribute(descriptor.getObjectName(), descriptor.getDataPath())).longValue());
|