ReconfigDispatcher.java

package org.objectweb.jonas.management;

// JMX import
import javax.management.ListenerNotFoundException;
import javax.management.MBeanNotificationInfo;
import javax.management.Notification;
import javax.management.NotificationBroadcasterSupport;
import javax.management.NotificationFilter;
import javax.management.NotificationListener;

import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public class ReconfigDispatcher extends NotificationBroadcasterSupport implements ReconfigDispatcherMBean {

    private static Logger slogger = null;

    public static final String RECONFIG_TYPE = "jonas.management.reconfiguration";
    public static final String SAVE_RECONFIG_TYPE = "jonas.management.reconfiguration.save";
    final String RECONFIG_NOTIF_CLASS = "jmx.management.Notification";
    final String SAVE_RECONFIG_NOTIF_CLASS = "jmx.management.Notification";

    ListenerJavaBean myListener = null;

    public void initLogger(Logger mylogger) {
        slogger = mylogger;
    }

    public void addNotificationListener(NotificationListener listner,
                                        NotificationFilter filter,
                                        java.lang.Object handback)
        throws java.lang.IllegalArgumentException {

        if (handback != null)
            slogger.log(BasicLevel.DEBUG, "handback: " + handback.toString());

        if (myListener == null) {
            slogger.log(BasicLevel.DEBUG, "Register the listener");
        } else {
            slogger.log(BasicLevel.DEBUG, "Caution : Re-register a listener !!! ");
        }
        myListener = new ListenerJavaBean(listner, filter, handback);
    }
    public void removeNotificationListener(NotificationListener listner) throws ListenerNotFoundException {
        NotificationListener registeredListener = myListener.getListener();
        if (registeredListener.equals(listner))
            myListener = null;
    }
    public MBeanNotificationInfo[] getNotificationInfo() {
        String[] notifsType = new String[2];
        notifsType[0] = new String(RECONFIG_TYPE);
        notifsType[1] = new String(SAVE_RECONFIG_TYPE);

        MBeanNotificationInfo[] myNotifInfos = new MBeanNotificationInfo[2];
        MBeanNotificationInfo myNotifInfo = new MBeanNotificationInfo(notifsType, RECONFIG_NOTIF_CLASS, "Notify service reconfiguration events");
        myNotifInfos[0] = myNotifInfo;

        myNotifInfo = new MBeanNotificationInfo(notifsType, SAVE_RECONFIG_NOTIF_CLASS, "Notify save reconfiguretion events");
        myNotifInfos[1] = myNotifInfo;

        return myNotifInfos;
    }

    public NotificationListener getListener() {
        if (myListener != null)
            return myListener.getListener();
        else
            return null;
    }
    public NotificationFilter getFilter() {
        if (myListener != null)
            return myListener.getFilter();
        else
            return null;
    }
    public java.lang.Object getHandback() {
        if (myListener != null)
            return myListener.getHandback();
        else
            return null;
    }

    public void sendSaveNotification(long sequenceNumber, String resourceName) {
        // create notification
        Notification saveNotif = new Notification(SAVE_RECONFIG_TYPE, this, sequenceNumber, resourceName);
        slogger.log(BasicLevel.DEBUG, saveNotif.getType() + " notification object created");

        // get listener and emit notification to it
        NotificationListener listenerMBean = getListener();
        Object handback = getHandback();
        if (listenerMBean != null)
            listenerMBean.handleNotification(saveNotif, handback);
        else
            slogger.log(BasicLevel.ERROR, "MBean can't send management notification as no listener registered !!");
    }

    public void sendReconfigNotification(long sequenceNumber, String resourceName, Object userData) {
        // create notification and set the userData
        Notification configNotif =  new Notification(RECONFIG_TYPE, this, sequenceNumber, resourceName);
        configNotif.setUserData(userData);
        slogger.log(BasicLevel.DEBUG, configNotif.getType() + " notification object created");

        // get listener and emit notification to it
        NotificationListener listenerMBean = getListener();
        Object handback = getHandback();
        if (listenerMBean != null) {
            listenerMBean.handleNotification(configNotif, handback);
        } else
            slogger.log(BasicLevel.ERROR, "MBean can't send management notification as no listener registered !!");
    }
}

---