DiscoveryClient.java

package org.objectweb.jonas.discovery;

import java.net.InetAddress;
import java.net.UnknownHostException;

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

import org.objectweb.jonas.common.Log;
import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public class DiscoveryClient extends NotificationBroadcasterSupport implements
    DiscoveryClientMBean,
    MBeanRegistration {
    private int                     sourcePort;
    private String                  sourceIp;
    private MBeanServer             mbeanServer;
    private ObjectName              myOn;
    private DiscoveryClientListener dcl                     = null;
    private Thread                  discoveryClientListener = null;
    private int                     ttl                     = 1;
    private int                     timeout                 = 1000;
    private int                     listeningPort;
    private String                  listeningIp;
    private static Logger           logger                  = Log.getLogger(Log.JONAS_DISCOVERY_PREFIX);

    public DiscoveryClient(int listeningPort, String listeningIP, int sourcePort) {
      this.listeningIp = listeningIP;
      this.listeningPort = listeningPort;
      this.sourcePort =sourcePort;
    }

    public int getTimeout() {
        return timeout;
    }

    public void setTimeout(int timeout) {
        this.timeout = timeout;
    }

    public int getListeningPort() {
        return listeningPort;
    }

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

    }

    public String getListeningIp() {
        return listeningIp;
    }

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

    }

    public int getSourcePort() {
        return sourcePort;
    }

    public void setSourcePort(int sourcePort) {
        this.sourcePort = sourcePort;

    }

    public String getSourceIp(){
        return sourceIp;
    }

    public int getTimeToLive() {
        return ttl;
    }

    public void setSourceIp(String sourceIp) {
        this.sourceIp = sourceIp;

    }

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

    }

    public void start() {
        // create the thread in charge of sending the discovery message and waiting
        // for the responses
        // creates an instance of the DiscoveryClientListener class
        try {
            this.setSourceIp(InetAddress.getLocalHost().getHostName());
        } catch (UnknownHostException e) {
            logger.log(BasicLevel.ERROR, "Unable to create a localhost.");
            e.printStackTrace();
        }
        dcl = new DiscoveryClientListener(this);

        if (discoveryClientListener == null) {
            discoveryClientListener = new Thread(dcl, "discoveryClientListener");
        }
        discoveryClientListener.start();

    }

    public void stop() {

    }

    public ObjectName preRegister(MBeanServer mbeanServer, ObjectName on) {
        //  set mbeanServer
        this.mbeanServer = mbeanServer;
        this.myOn = on;

        return myOn;
    }

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

    public void preDeregister() throws Exception {
        dcl.stop();

    }

    public void postDeregister() {
    }

}

---