On Friday 07 May 2004 06:39, Scott Brickner wrote:
> I'm using JMX fairly extensively with Merlin 3.2.5 - I rolled my own bit
> of magic using an @avalon.extension component. The extension creates an
> mbean server, an HTTP adaptor, and a remote connector.
I am quite impressed, that people manages to roll their own through the fairly
simple LifeCycle extension mechanism...
I think the full code per se is not 'candidate' for inclusion into the JMX
facility.
> Basically, if you mark a class as being "manageable" (i.e., mark it as
> using the extension), then the manager will automatically register the
> mbean with the mbeanServer when the component is deployed and then
> unregisters it when it's deployed.[sic!]
I think the 'marker' should be a method level meta-info tag, for instance
@avalon.jmx.management
And that the meta-info task creates the necessary info into the .xinfo file,
and the JMX facility picks that up and adds the method to the management
interface.
Cameron, if you are up for the task to make the "@avalon.jmx.management"
mechanism, with my help outside the JMX Facility, give me a time when you can
chat over IRC, so we can help each other forward on this...
Scott, thanks for the contribution, although we may or may not use the code
below, you have at least fueled the JMX fire, which is positive for those
involved.
Merlin 3.3 is going out through the door "real soon now", BUT the facilities
are not part of the distro anymore. We will roll the facilities one by one as
they ready for wider community tests. In the pipeline for the facilities are;
embedded http server, JMX, Message-Driven service, embedded Database.
Milage varies...
Cheers
Niclas
> It automatically assigns ObjectNames based on the implementation package
> of the deployed component and the component's block name (i.e.,
> "com.mycompany.myproject.mypackage:block=myBlockName"). Alternatively,
> the component can implement a Manageable interface that the management
> extension will use to get a name for the object.
>
> Currently, there's no effort to make ObjectNames unique to support
> non-singleton component lifestyles - I haven't needed it for my project,
> so I didn't build it. Someone with a better understanding of Merlin's
> innards might be able to do that quite easily.
>
> If anyone thinks this code would be useful, I'll happily contribute it.
>
> Here you go...
>
> /**
> * @avalon.stage id='urn:flashtalk.com:manageable'
> */
> public interface Manageable {
> String getManagementName();
> }
>
> import java.io.File;
> import javax.management.Attribute;
> import javax.management.InstanceNotFoundException;
> import javax.management.MalformedObjectNameException;
> import javax.management.MBeanRegistrationException;
> import javax.management.MBeanServer;
> import javax.management.MBeanServerFactory;
> import javax.management.ObjectName;
> import mx4j.adaptor.http.HttpAdaptor;
> import org.apache.avalon.framework.activity.Disposable;
> import org.apache.avalon.framework.activity.Initializable;
> import org.apache.avalon.framework.activity.Startable;
> import org.apache.avalon.framework.configuration.Configurable;
> import org.apache.avalon.framework.configuration.Configuration;
> import org.apache.avalon.framework.configuration.ConfigurationException;
> import org.apache.avalon.framework.context.Context;
> import org.apache.avalon.framework.context.ContextException;
> import org.apache.avalon.framework.logger.LogEnabled;
> import org.apache.avalon.framework.logger.Logger;
> import org.apache.avalon.lifecycle.Creator;
>
> import javax.management.remote.JMXServiceURL;
> import javax.management.remote.JMXConnectorServer;
> import javax.management.remote.JMXConnectorServerFactory;
>
> /**
> * @avalon.component name='managementServer' lifestyle='singleton'
> * @avalon.extension id='urn:flashtalk.com:manageable'
> */
> public class ManagementServer implements Creator, LogEnabled,
> Configurable, Initializable, Startable, Disposable {
> private Logger logger;
>
> public static final int DEFAULT_PORT = 9999;
>
> private MBeanServer mbeanServer;
> private HttpAdaptor httpAdaptor;
> private JMXConnectorServer connectorServer;
>
> private int port;
>
> public void enableLogging( Logger logger) { this.logger = logger; }
>
> public void configure( Configuration configuration) throws
> ConfigurationException {
> port = configuration.getChild( "port").getValueAsInteger(
> DEFAULT_PORT);
> }
>
> public void initialize() throws Exception {
> mbeanServer = MBeanServerFactory.createMBeanServer();
> httpAdaptor = new HttpAdaptor();
> ObjectName name = new ObjectName( "Server:name=HttpAdaptor");
> mbeanServer.registerMBean( httpAdaptor, name);
> httpAdaptor.setPort( port);
>
> ObjectName processorName = new ObjectName(
> "Server:name=XSLTProcessor");
> mbeanServer.createMBean( "mx4j.adaptor.http.XSLTProcessor",
> processorName, null);
> mbeanServer.setAttribute( name, new Attribute( "ProcessorName",
> processorName));
> mbeanServer.setAttribute( processorName, new Attribute( "File",
> System.getProperty( "user.home") + File.separator +
> "merlin/repository/mx4j/jars/mx4j-tools.1.1.1.jar"));
> mbeanServer.setAttribute( processorName, new Attribute( "PathInJar",
> "mx4j/adaptor/http/xsl"));
> mbeanServer.setAttribute( processorName, new Attribute( "UseCache",
> Boolean.FALSE));
>
> logger.info( "creating RMI connector server");
> JMXServiceURL url = new JMXServiceURL(
> "service:jmx:rmi:///jndi/rmi://localhost/server");
> connectorServer = JMXConnectorServerFactory.newJMXConnectorServer(
> url, null, mbeanServer);
> logger.info( "created RMI connector server");
> }
>
> public void start() throws Exception {
> httpAdaptor.start();
> logger.info( "starting RMI connector server");
> connectorServer.start();
> logger.info( "started RMI connector server");
> }
>
> public void stop() throws Exception {
> httpAdaptor.stop();
> logger.info( "stopping RMI connector server");
> connectorServer.stop();
> logger.info( "stopped RMI connector server");
> }
>
> public void dispose() {
> MBeanServerFactory.releaseMBeanServer( mbeanServer);
> }
>
> public void create( Object object, Context context) throws Exception {
> String name = generateName( object, ( String) context.get(
> "urn:avalon:name"));
> if ( logger.isDebugEnabled()) logger.debug( "Registering " + object +
> " (" + name + ")");
> ObjectName objectName = new ObjectName( name);
> if ( !mbeanServer.isRegistered( objectName))
> mbeanServer.registerMBean( object, objectName);
> }
>
> private String generateName( Object object, String blockName) {
> if ( object instanceof Manageable) {
> Manageable manageable = ( Manageable) object;
> return manageable.getManagementName();
> }
> Class c = object.getClass();
> return c.getPackage().getName() + ":block=" + blockName;
> }
>
> public void destroy( Object object, Context context) {
> String name;
> try {
> name = generateName( object, ( String) context.get(
> "urn:avalon:name"));
> } catch ( ContextException e) {
> assert false;
> name = null;
> }
> if ( logger.isDebugEnabled()) logger.debug( "Releasing " + object + "
> (" + name + ")");
> try {
> mbeanServer.unregisterMBean( new ObjectName( name));
> } catch ( MalformedObjectNameException e) {
> if ( logger.isWarnEnabled()) logger.warn( "releasing " + name,
> e);
> } catch ( InstanceNotFoundException e) {
> if ( logger.isWarnEnabled()) logger.warn( "releasing " + name,
> e);
> } catch ( MBeanRegistrationException e) {
> if ( logger.isWarnEnabled()) logger.warn( "releasing " + name,
> e);
> }
> }
> }
>
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [EMAIL PROTECTED]
> For additional commands, e-mail: [EMAIL PROTECTED]
--
+---------//-------------------+
| http://www.bali.ac |
| http://niclas.hedhman.org |
+------//----------------------+
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
