Enroller.java

package org.objectweb.jonas.discovery;

import javax.management.MBeanRegistration;
import javax.management.MBeanServer;
import javax.management.NotificationBroadcasterSupport;
import javax.management.ObjectName;

public class Enroller extends NotificationBroadcasterSupport
    implements MBeanRegistration, EnrollerMBean {

    private int listeningPort;
    private String listeningIp = null;
    private MBeanServer   mbeanServer;
    private ObjectName    myOn;
    private Thread        discoveryListener = null;
    private DiscoveryListener dl = null;
    private int ttl =1;

    public Enroller (int listeningPort, String listeningIp) {
      this.listeningIp = listeningIp;
      this.listeningPort = listeningPort;
    }

    public ObjectName preRegister(MBeanServer mbeanServer, ObjectName on)
    throws Exception {
        this.mbeanServer = mbeanServer;
        this.myOn = on;
        return myOn;
    }

    public void postRegister(Boolean arg0) {
        start();
    }

    public void preDeregister() throws Exception {
        // stop the listening thread
        dl.stopListener();
        discoveryListener.interrupt();
        discoveryListener= null;
    }

    public void postDeregister() {

    }

    public int getListeningPort() {
        return listeningPort;
    }

    public void setListeningPort(int listeningPort) {
        this.listeningPort = listeningPort;

    }

    public String getListeningIp() {
        return listeningIp;
    }

    public void setListeningIp(String listeningIp) {
        this.listeningIp = listeningIp;

    }

    public void setTimeToLive(int ttl) {
        this.ttl = ttl;

    }

    public int getTimeToLive() {
        return ttl;
    }

    public void start() {
        // creates an instance of the Discovery communication class
        dl = new DiscoveryListener(this);

        if (discoveryListener == null)
            discoveryListener = new Thread(dl, "discoveryListener");
        discoveryListener.start();

    }
   public void stop() {
       dl.stopListener();
   }
}

---