/*
 * MulticastReceiver.java
 *
 * Created on den 6 september 2001, 17:02
 */

package ip1.u4.net;

import java.net.*;
import java.io.*;
/** Tar emot multicastmeddelanden från angiven adress på specificerad poer.
 * <CODE>MulticastReceiver</CODE> ligger i en egen tråd, när meddelande uppfångats
 * skickas det vidare till en <CODE>DatagramReceiver</CODE> för vidare prosessning.
 *
 * @author Henrik Johansson
 * @version 1.0
 * @see DatagramReceiver
 */
public class MulticastReceiver implements Runnable {

    private DatagramReceiver receiver = null;
    
    private InetAddress address = null;
    
    private int port;
    
    private MulticastSocket socket;
    
    private boolean running;
    
    /** Skapar ny <CODE>MulticastReceiver.</CODE> Denna anmäler sig till multicastadressen
     * <CODE>address</CODE> och lyssnar på port <CODE>port</CODE>, mottagna meddelanden
     * skickas vidare till <CODE>receiver</CODE>.
     *
     * @param address Adressen <CODE>MulticastReceiver</CODE> anmäler sig till.
     * @param port port <CODE>MulticastReceiver</CODE> lyssnar på.
     * @param receiver <CODE>DatagramReceiver</CODE> som prosessar meddelanden.
     * @throws IOException Kastas om <CODE>MulticastReceiver</CODE> inte kan anmäla sig till
     * multicastadressen <CODE>address</CODE>
     */
    public MulticastReceiver(InetAddress address, int port, DatagramReceiver receiver) throws IOException{
        this.address = address;
        this.port = port;
        this.receiver = receiver;
        socket = new MulticastSocket(port);
        socket.joinGroup(address);
        running = true;
        (new Thread(this)).start();
    }

    /** Stänger av <CODE>MulticastReseiver</CODE>. Porten stängd och kan inte återöppnas
     * utan att ny instans skapas.
     */    
    public void close() {
        running = false;
        socket.close();
    }
    
    /** För att få veta multicastadressen <CODE>MulticastReceiver</CODE> anmält sig till.
     * @return adress <CODE>MulticastReceiver</CODE> anmält sig till.
     */    
    public String getHost() {
        return address.getHostAddress();
    }
    
    /** För att få veta porten <CODE>MulticastReceiver</CODE> lyssnar på.
     * @return port <CODE>MulticastReceiver</CODE> lyssnar på.
     */    
    public int getPort() {
        return port;
    }
    
    /** implementation av Runnableinterfacet
     */    
    public void run() {
        while(running) {
            try {
                DatagramPacket m = new DatagramPacket(new byte[1024], 1024);
                socket.receive(m);
                receiver.processMessage(m);
            } catch(IOException e) {
                System.err.println(e);
            }
        }
    }
}