DiscMessage.java

package org.objectweb.jonas.discovery;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.Serializable;
import java.net.DatagramPacket;

public class DiscMessage implements Serializable {
        private String sourceAddress;
        private int sourcePort;

    public DiscMessage(String sourceAddress, int sourcePort) {
        this.sourceAddress = sourceAddress;
        this.sourcePort = sourcePort;
    }

    public String getSourceAddress() {
        return sourceAddress;
    }

    public int getSourcePort() {
        return sourcePort;
    }

    public void setSourceAddress(String sourceAddress) {
        this.sourceAddress = sourceAddress;
    }

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

    public static byte[] objectToBytes(Serializable obj) {
        if (obj == null) {
            return null;
        }
        try {
            ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
            new ObjectOutputStream(byteStream).writeObject(obj);
            return byteStream.toByteArray();
        } catch (IOException ex) {
            throw new IllegalArgumentException(ex.toString());
        }
    }

    private static DatagramPacket getDatagram(Serializable o) {
        byte[] content = objectToBytes(o);
        if (content == null) {
            return null;
        }
        DatagramPacket dp = new DatagramPacket(content, content.length);
        return dp;
    }

    public String toString() {
        String messageString = null;
        messageString = sourceAddress + ":" + sourcePort;
        return messageString;
    }

}

---