public static  void listServices(RemoteMBeanServer pConnector) throws Exception 
{
		try {
			Iterator i = pConnector.queryMBeans( null, null ).iterator();
			while( i.hasNext() ) {
				MBeanInfo info = pConnector.getMBeanInfo( ( (ObjectInstance) i.next() ).getObjectName() );
				System.out.println( "MBean: " + info.getClassName() );
				MBeanAttributeInfo[] aInfos = info.getAttributes();
				for( int k = 0; k <  aInfos.length; k++ ) {
					System.out.println( "\t" + k + ". Attribute: " +
					aInfos[ k ].getName() );
				}
				MBeanOperationInfo[] oInfos = info.getOperations();
				for( int k = 0; k <  oInfos.length; k++ ) {
					System.out.println( "\t" + k + ". Operation: " +
					oInfos[ k ].getName() );
				}
			}
		}
		catch (Exception e) {
			e.printStackTrace();
		}
}

 public static  void main(String[] args) throws Exception 
{
		try {
			System.out.println(  );
			getUserInput(
				"Testing JMX Connectors\n" +
				"======================\n\n" +
				"1. Instantiate local MBeanServer and add connector " +
				"factory as first MBean to search your net\n" +
				"= > hit any key to proceed"
			);
			// First create a MBeanServer and let it start
			final MBeanServer lLocalServer = MBeanServerFactory.createMBeanServer();
			// Then register the connector factory
			final ObjectInstance lFactoryInstance = lLocalServer.createMBean(
				"org.jboss.jmx.connector.ConnectorFactoryService",
				new ObjectName( lLocalServer.getDefaultDomain(), "name", "ConnectorFactory" )
			);
			System.out.println( "Found Factory: " + lFactoryInstance.getObjectName() );
			int lType = -1;
         while( lType <  1 || lType  > 3 ) {
            lType = getUserInput(
               "\n" +
               "2. Do you want to use RMI or JMS to transfer Notifications\n" +
               "= > enter 1 from RMI, 2 for JMS or 3 for Polling and then hit enter"
            );
            System.out.println( "Type: " + lType );
         }
         switch( lType ) {
            case 1:
               lType = RemoteMBeanServer.NOTIFICATION_TYPE_RMI;
               break;
            case 2:
               lType = RemoteMBeanServer.NOTIFICATION_TYPE_JMS;
               break;
            case 3:
               lType = RemoteMBeanServer.NOTIFICATION_TYPE_POLLING;
         }
			lLocalServer.setAttribute(
				lFactoryInstance.getObjectName(),
            new Attribute( "NotificationType", new Integer( lType ) )
         );
         String lJMSName = null;
         if( lType == RemoteMBeanServer.NOTIFICATION_TYPE_JMS ) {
            while( lJMSName == null || lJMSName.trim().length() == 0 ) {
               lJMSName = getUserInputLine(
                  "\n" +
                  "2.a. Enter the JMS Queue Factory Name and hit enter\n"
               );
            }
         }
         if( lJMSName == null || lJMSName.trim().length() == 0 ) {
            lJMSName = null;
         }
			lLocalServer.setAttribute(
				lFactoryInstance.getObjectName(),
            new Attribute( "JMSName", lJMSName )
         );
         String lEJBAdaptorName = getUserInputLine(
            "\n" +
            "3. When you are expecting EJB-Connectors and the EJB-Adaptor\n" +
            "   and the EJB-Adaptor does not have the default JNDI-Name then\n" +
            "   then specified it here and hit enter\n"
         );
         if( lEJBAdaptorName == null || lEJBAdaptorName.trim().length() == 0 ) {
            lEJBAdaptorName = null;
         }
			lLocalServer.setAttribute(
				lFactoryInstance.getObjectName(),
            new Attribute( "EJBAdaptorName", lEJBAdaptorName )
         );
         // Init and start Factory because all attributes are set
			lLocalServer.invoke(
				lFactoryInstance.getObjectName(),
				"create",
				new Object[] {},
				new String[] {}
			);
			lLocalServer.invoke(
				lFactoryInstance.getObjectName(),
				"start",
				new Object[] {},
				new String[] {}
			);
			getUserInput(
				"\n" +
				"4. Lookup for all available connectors with the JNDI defined by jndi.properties\n" +
				"= > hit any key to proceed"
			);
			// Now let's list the available JMX Connectors
         InitialContext lContext = null;
         try {
            lContext = new InitialContext();
         }
         catch( Exception e ) {
            e.printStackTrace();
         }
         Hashtable lProperties = lContext.getEnvironment();
         ConnectorFactoryImpl.JBossConnectorTester lTester = new ConnectorFactoryImpl.JBossConnectorTester();
			Iterator lConnectors = (Iterator) lLocalServer.invoke(
				lFactoryInstance.getObjectName(),
				"getConnectors",
				new Object[] {
					lProperties,
               lTester
				},
				new String[] {
               Hashtable.class.getName(),
               ConnectorFactoryImpl.IConnectorTester.class.getName()
				}
			);
			int lCount = 0;
			StringBuffer lMessage = new StringBuffer();
			lMessage.append( "List of all available connectors on your net\n" );
			lMessage.append( "=========================================\n" );
         Vector lTemp = new Vector();
			while( lConnectors.hasNext() ) {
            ConnectorFactoryImpl.ConnectorName lName = (ConnectorFactoryImpl.ConnectorName) lConnectors.next();
            lTemp.addElement( lName );
				lMessage.append( " - " + ( lCount++ ) + ". connector is: " + lName + "\n" );
			}
         int lChoice = -1;
         while( lChoice <  0 || lChoice  > lTemp.size() ) {
            lMessage.append( "\n" );
            lMessage.append( "5. Select your connector by entering its number\n" );
            lMessage.append( "= > hit any key to proceed" );
            lChoice = getUserInput( lMessage.toString() );
         }
			final ConnectorFactoryImpl.ConnectorName lConnectorName = (ConnectorFactoryImpl.ConnectorName) lTemp.get( lChoice );
			lMessage.setLength( 0 );
			lMessage.append(
				"\n" +
				"You selected connector: " + lConnectorName + "\n\n"
			);
			getUserInput(
            lMessage.toString() + "\n" +
				"6. Connect to the given connector\n" +
				"= > hit any key to proceed"
			);
         lMessage.setLength( 0 );
			// Take the first server and its first protoccol and create a
			// connection to the remote MBeanServer
			RemoteMBeanServer lConnector = (RemoteMBeanServer) lLocalServer.invoke(
				lFactoryInstance.getObjectName(),
				"createConnection",
				new Object[] {
					lConnectorName
				},
				new String[] {
               lConnectorName.getClass().getName()
				}
			);
			getUserInput(
				"\n" +
				"7. List all available MBeans and its attributes\n" +
				"= > hit any key to proceed"
			);
			// List all services
			listServices( lConnector );
			getUserInput(
				"\n" +
				"8. Try to add a listener to all available MBeans.\n" +
				"Please note that this will keep this test client up and running waiting\n" +
				"for an event from the server. If there is no event comming then try\n" +
				"to shutdown the JBoss server.\n" +
				"To end this test client just hit < CTRL >-C\n"+
				"= > hit any key to proceed"
			);
			// Try to register to all available, remote MBeans
			registerListeners( lConnector );
			// Add shutdown hook to remove the connection before shut down
			try {
				Runtime.getRuntime().addShutdownHook(
					new Thread() {
						public void run() {
							System.err.println( "Shutdown" );
							try {
								lLocalServer.invoke(
									lFactoryInstance.getObjectName(),
									"removeConnection",
									new Object[] {
										lConnectorName
									},
									new String[] {
                              lConnectorName.getClass().getName()
									}
								);
								System.err.println("Shutting done");
							}
							catch( Throwable e ) {
								e.printStackTrace();
							}
						}
					}
				);
				System.out.println ("Shutdown hook added");
			}
			catch ( Throwable e ) {
				System.out.println( "Could not add shutdown hook" );
				// JDK 1.2.. ignore!
			}
		}
		catch( RuntimeMBeanException rme ) {
			System.err.println( "TestClient.main(), caught: " + rme +
				", target: " + rme.getTargetException() );
			rme.printStackTrace();
		}
		catch( MBeanException me ) {
			System.err.println( "TestClient.main(), caught: " + me +
				", target: " + me.getTargetException() );
			me.printStackTrace();
		}
		catch( RuntimeErrorException rte ) {
			System.err.println( "TestClient.main(), caught: " + rte +
				", target: " + rte.getTargetError() );
			rte.printStackTrace();
		}
		catch( ReflectionException re ) {
			System.err.println( "TestClient.main(), caught: " + re +
				", target: " + re.getTargetException() );
			re.printStackTrace();
		}
		catch( Exception e ) {
			System.err.println( "TestClient.main(), caught: " + e );
			e.printStackTrace();
		}
}

 public static  void registerListeners(RemoteMBeanServer pConnector) throws Exception 
{
		try {
			// Add a listener to all of the available MBeans
			Iterator i = pConnector.queryMBeans( null, null ).iterator();
			int j = 0;
			while( i.hasNext() ) {
				ObjectName lBean = ( (ObjectInstance) i.next() ).getObjectName();
				try {
               if( pConnector.isInstanceOf( lBean, "javax.management.NotificationBroadcaster" ) ) {
                  pConnector.addNotificationListener(
                     lBean,
                     (NotificationListener) new Listener(),
                     (NotificationFilter) null,
                     new NotSerializableHandback(
                        lBean + "" + j++
                     )
                  );
                  System.out.println( "Added notification listener to: " + lBean );
               } else {
                  System.out.println( "This MBean is not a notification broadcaster: " + lBean );
               }
				}
				catch( RuntimeOperationsException roe ) {
					System.out.println( "Could not add listener to: " + lBean +
						", reason could be that it is not a broadcaster" );
				}
				catch( Exception e ) {
					e.printStackTrace();
				}
			}
		}
		catch (Exception e) {
			e.printStackTrace();
		}
}