1 /*

     2  * Copyright 2005 Sun Microsystems, Inc.  All Rights Reserved.

     3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

     4  *

     5  * This code is free software; you can redistribute it and/or modify it

     6  * under the terms of the GNU General Public License version 2 only, as

     7  * published by the Free Software Foundation.

     8  *

     9  * This code is distributed in the hope that it will be useful, but WITHOUT

    10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

    11  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

    12  * version 2 for more details (a copy is included in the LICENSE file that

    13  * accompanied this code).

    14  *

    15  * You should have received a copy of the GNU General Public License version

    16  * 2 along with this work; if not, write to the Free Software Foundation,

    17  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

    18  *

    19  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,

    20  * CA 95054 USA or visit www.sun.com if you need additional information or

    21  * have any questions.

    22  */

    23 

    24 /*

    25  * @test

    26  * @bug 6238815

    27  * @summary test the new interface Addressable

    28  * @author Shanliang JIANG

    29  * @run clean AddressableTest

    30  * @run build AddressableTest

    31  * @run main AddressableTest

    32  */

    33 

    34 import java.util.*;

    35 import java.net.MalformedURLException;

    36 import java.io.IOException;

    37 

    38 import javax.management.*;

    39 import javax.management.remote.*;

    40 import javax.management.remote.rmi.*;

    41 

    42 public class AddressableTest {

    43     private static final String[] protocols = {"rmi", "iiop"};

    44     private static final String[] prefixes = {"stub", "ior"};

    45 

    46     private static final MBeanServer mbs = MBeanServerFactory.createMBeanServer();

    47 

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

    49         System.out.println(">>> test the new interface Addressable.");

    50         boolean ok = true;

    51 

    52         for (int i = 0; i < protocols.length; i++) {

    53             try {

    54                 test(protocols[i], prefixes[i]);

    55 

    56                 System.out.println(">>> Test successed for "+protocols[i]);

    57             } catch (Exception e) {

    58                 System.out.println(">>> Test failed for "+protocols[i]);

    59                 e.printStackTrace(System.out);

    60                 ok = false;

    61             }

    62         }

    63 

    64         if (ok) {

    65             System.out.println(">>> All Test passed.");

    66         } else {

    67             System.out.println(">>> Some TESTs FAILED");

    68             System.exit(1);

    69         }

    70     }

    71 

    72     public static void test(String proto, String prefix) throws Exception {

    73         JMXServiceURL url = new JMXServiceURL("service:jmx:" + proto + "://");

    74         JMXConnectorServer server =

    75                     JMXConnectorServerFactory.newJMXConnectorServer(url, null, mbs);

    76 

    77         server.start();

    78 

    79         JMXServiceURL serverAddr1 = server.getAddress();

    80         System.out.println(">>> Created a server with address "+serverAddr1);

    81 

    82         JMXConnector client1 = JMXConnectorFactory.connect(serverAddr1);

    83         JMXServiceURL clientAddr1 = ((JMXAddressable)client1).getAddress();

    84 

    85         System.out.println(">>> Created a client with address "+clientAddr1);

    86 

    87         if (!serverAddr1.equals(clientAddr1)) {

    88             throw new RuntimeException("The "+proto+" client does not return correct address.");

    89         }

    90 

    91         int i = clientAddr1.toString().indexOf(prefix);

    92 

    93         JMXServiceURL clientAddr2 =

    94             new JMXServiceURL("service:jmx:"+proto+":///"+clientAddr1.toString().substring(i));

    95 

    96         JMXConnector client2 = JMXConnectorFactory.connect(clientAddr2);

    97 

    98         System.out.println(">>> Created a client with address "+clientAddr2);

    99 

   100         if (!clientAddr2.equals(((JMXAddressable)client2).getAddress())) {

   101             throw new RuntimeException("The "+proto+" client does not return correct address.");

   102         }

   103 

   104         System.out.println(">>> The new client's host is "+clientAddr2.getHost()

   105                                +", port is "+clientAddr2.getPort());

   106 

   107         client1.close();

   108         client2.close();

   109         server.stop();

   110     }

   111 }