Example 2.1. Specifying description for standard MBeans

		
public interface MyServiceMBean
{
	public void start();
	public void setStatus(int status);
}

public class MyService implements MyServiceMBean
{
	public MyService(String type) {...}
	public void start() {...}
	public void stop() {...}
	public void setStatus(int status) {...}
}

public class MyServiceMBeanDescription extends MBeanDescriptionAdaptor
{
	public String getConstructorDescription(Constructor ctor)
	{
		// Only one constructor
		return "Creates a new instance of my personal service";
	}

	public String getConstructorParameterName(Constructor ctor, int index)
	{
		// Constructor has only one parameter
		return "type";
	}

	public String getConstructorParameterDescription(Constructor ctor, int index)
	{
		// Constructor has only one parameter
		return "The type of the service. Valid values are 'VOLATILE' or 'PERMANENT'.";
	}

	public String getAttributeDescription(String attribute)
	{
		// There is only one attribue, 'Status'
		return "The status of the service. Can be set to ON=1, OFF=0";
	}

	public String getOperationDescription(Method operation)
	{
		String name = operation.getName();
		if (name.equals("start"))
		{
			return "Starts the service. After the service is started its status is ON";
		}
		else if (name.equals("stop"))
		{
			return "Stops the service. After the service is stopped its status is OFF";
		}
		else
		{
			return super.getOperationDescription(operation);
		}
	}
}
		
		

Example 2.2. Typical MBeanServer.invoke invocation

		
public interface PersisterMBean
{
	public void store(Object data) throws MBeanException, RuntimeOperationsException, InstanceNotFoundException;
	...
}

public abstract class Persister implements PersisterMBean {}

public class MBeanPersister extends Persister
{
	private MBeanServer m_server;
	private ObjectName m_name;

	public MBeanPersister(MBeanServer server, ObjectName name)
	{
		m_server = server;
		m_name = name;
	}
	public void store(Object data) throws MBeanException, RuntimeOperationsException, InstanceNotFoundException
	{
		try
		{
			m_server.invoke(m_name, "store", new Object[] {data}, new String[] {"java.lang.Object"});
		}
		catch (ReflectionException x)
		{
			throw new MBeanException(x.getTargetException());
		}
	}
}
		
		

Example 2.3. Proxy MBeanServer invocation

		
public class MBeanPersister extends Persister
{
	private MBeanServer m_server;
	private ObjectName m_name;
	private PersisterMBean m_proxy;

	public MBeanPersister(MBeanServer server, ObjectName name)
	{
		m_server = server;
		m_name = name;
		m_proxy = (PersisterMBean)StandardMBeanProxy.create(PersisterMBean.class, server, name);
	}
	public void store(Object data) throws MBeanException, RuntimeOperationsException, InstanceNotFoundException
	{
		m_proxy.store(data);
	}
}
		
		

Example 2.4. Logging redirection to Log4J

		
import org.apache.log4j.PropertyConfigurator;
import openjmx.log.*;

public class Main
{
	public static void main(String[] args) throws Exception
	{
		// Configure Log4J
		PropertyConfigurator.configureAndWatch("log4j.properties");
		// Or use the XML version below
		// DOMConfigurator.configureAndWatch("log4j.xml");

		// Redirect OpenJMX logging to Log4J
		Log.redirectTo(new Log4JLogger());

		// Normal code here
		MBeanServer server = MBeanServerFactory.createMBeanServer();
		...

		// Reset redirection, log in the normal way (to console)
		Log.redirectTo(null);
	}
}
		
		

Example 2.5. Logging redirection to the broadcaster MBean

		
import openjmx.log.*;

public class Main
{
	public static void main(String[] args) throws Exception
	{
		MBeanServer server = MBeanServerFactory.createMBeanServer();

		// Register the broadcaster logger mbean
		ObjectName name = new ObjectName("Logger:type=broadcaster");
		server.createMBean("openjmx.log.LoggerBroadcaster", name, null);

		// The filter: only errors are logged
		NotificationFilter filter = new NotificationFilter()
		{
			public boolean isNotificationEnabled(Notification notification)
			{
				if (notification.getType().equals("openjmx.logger.error")) {return true;}
				return false;
			}
		};

		// The listener: logs on System.err instead of System.out
		NotificationListener listener = new NotificationListener()
		{
			public void handleNotification(Notification notification, Object handback)
			{
				System.err.println("[OpenJMX ERROR]: " + notification);
			}
		};

		// Register the listener along with the filter
		server.addNotificationListener(name, listener, filter, null);

		// Starts the redirector
		LoggerBroadcasterMBean redirector = (LoggerBroadcasterMBean)MBeanProxy.create(LoggerBroadcasterMBean.class, server, name);
		redirector.start();

		...

		// Stops the redirector
		redirector.stop();
	}
}