udpmessagesender.java

Peers is a very minimalistic SIP User-Agent. It s a softphone, written in java, and it has been test

/*
    This file is part of Peers.

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    Copyright 2007, 2008 Yohann Martineau 
*/

package net.sourceforge.peers.sip.transport;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

import net.sourceforge.peers.Logger;
import net.sourceforge.peers.sip.RFC3261;
import net.sourceforge.peers.sip.Utils;


public class UdpMessageSender extends MessageSender {

    private DatagramSocket datagramSocket;
    
    public UdpMessageSender(InetAddress inetAddress, int port,
            DatagramSocket datagramSocket)
            throws SocketException {
        super(inetAddress, port);

        this.datagramSocket = datagramSocket;
        StringBuffer buf = new StringBuffer();
        //buf.append(datagramSocket.getLocalAddress().getHostAddress());
        buf.append(Utils.getInstance().getMyAddress().getHostAddress());
        buf.append(RFC3261.TRANSPORT_PORT_SEP);
        buf.append(datagramSocket.getLocalPort());
        buf.append(RFC3261.PARAM_SEPARATOR);
        buf.append(RFC3261.PARAM_TRANSPORT);
        buf.append(RFC3261.PARAM_ASSIGNMENT);
        buf.append(RFC3261.TRANSPORT_UDP);
        contact = buf.toString();
        localPort = datagramSocket.getLocalPort();
    }

    @Override
    public synchronized void sendMessage(SipMessage sipMessage) throws IOException {
        byte[] buf = sipMessage.toString().getBytes();
        DatagramPacket packet = new DatagramPacket(buf, buf.length, inetAddress,
                port);
        datagramSocket.send(packet);
        Logger.getInstance().traceNetwork(new String(packet.getData()), "SENT");
    }

}