DiameterMessage.java

Go to the documentation of this file.

/*
 * $Id: DiameterMessage.java 167 2007-03-05 09:25:42Z shenny $
 *
 * Copyright (C) 2004-2006 FhG Fokus
 *
 * This file is part of Open IMS Core - an open source IMS CSCFs & HSS
 * implementation
 *
 * Open IMS Core 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 2 of the License, or
 * (at your option) any later version.
 *
 * For a license to use the Open IMS Core software under conditions
 * other than those described here, or to purchase support for this
 * software, please contact Fraunhofer FOKUS by e-mail at the following
 * addresses:
 *     info@open-ims.org
 *
 * Open IMS Core 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, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 */

package de.fhg.fokus.diameter.DiameterPeer.data;

import java.util.Vector;

import org.apache.log4j.Logger;


public class DiameterMessage {
    
    private static final Logger LOGGER = Logger.getLogger(DiameterMessage.class);

    int version=1;
    
    public int commandCode;
    
    public boolean flagRequest=true;
    
    public boolean flagProxiable=true;
    
    public boolean flagError=false;
    
    public boolean flagRetransmission=false;
    
    public int applicationID=0;
    
    public long hopByHopID=0;

    public long endToEndID=0;
    
    public Vector<AVP> avps;
    
    
    public long networkTime=0;

    
    public DiameterMessage()
    {
        avps = new Vector<AVP>();
    }
    
    public DiameterMessage(int Command_Code,boolean Request,boolean Proxiable,
            int Application_id,long HopByHop_id, long EndToEnd_id)
    {
        this.commandCode = Command_Code;
        this.flagRequest = Request;
        this.flagProxiable = Proxiable;
        this.applicationID = Application_id;
        this.hopByHopID = HopByHop_id;
        this.endToEndID = EndToEnd_id;
        avps = new Vector<AVP>();
    }
    
    public DiameterMessage(int Command_Code,boolean Request,int Application_id)
    {
        this.commandCode = Command_Code;
        this.flagRequest = Request;
        this.flagProxiable = false;
        this.applicationID = Application_id;
        avps = new Vector<AVP>();
    }
    
    public void addAVP(AVP child)
    {
        avps.add(child);
    }
    
    public int getAVPCount()
    {
        return avps.size();
    }
    
    public AVP getAVP(int index)
    {
        if (index<avps.size())
            return (AVP)avps.get(index);
        else return null;
    }
    
    public void deleteAVP(AVP avp)
    {
        avps.remove(avp);
    }
    
    public AVP findAVP(int Code,boolean Mandatory,int Vendor_id)
    {
        AVP avp;
        for(int i=0;i<avps.size();i++){
            avp = (AVP) avps.get(i);
            if (avp.code == Code &&
                avp.flag_mandatory == Mandatory &&
                avp.vendor_id == Vendor_id) 
                    return avp;
        }
        return null;
    }
    
    public AVP[] findAVPs(int Code)
    {
        AVP[] avpset;
        int j = 0, count = 0;
        AVP avp;
        
        for(int i=0;i<avps.size();i++){
            avp = (AVP) avps.get(i);
            if (avp.code == Code)
                count++;
        }
        
        if (count == 0) return null;
        avpset = new AVP[count];
        for(int i=0;i<avps.size();i++){
            avp = (AVP) avps.get(i);
            if (avp.code == Code) {
                avpset[j++] = avp;
                if (j == count) break;
            }
        }
        
        return avpset;
    }
    
    public AVP findAVP(int Code) {
        AVP avp;
        for(int i=0;i<avps.size();i++){
            avp = (AVP) avps.get(i);
            if (avp.code == Code) {
                
                return avp;
            }
        }
        return null;    
        
    }
    
    public AVP getSessionId() {
        return findAVP(AVP.Session_Id);
    }
    
    public String toString()
    {
        StringBuffer x = new StringBuffer();
        x.append("Diameter: Code=");x.append(commandCode);
        if (flagRequest) x.append(" R");
        if (flagProxiable) x.append(" P");
        if (flagError) x.append(" E");
        if (flagRetransmission) x.append(" T");
        
        x.append(" AppID=");x.append(applicationID);
        x.append(" HbHID=");x.append(hopByHopID);
        x.append(" E2EID=");x.append(endToEndID);
        
        x.append("\n");
        for(int i=0;i<avps.size();i++){
            x.append("\t");
            x.append(avps.get(i).toString());
            x.append("\n");
        }       
        return x.toString();
    }
    
    public static final int Code_CE=257;
    
    public static final int Code_DW=280;
    
    public static final int Code_DP=282;
    
    public static final int DIAMETER_SUCCESS = 2001;
    
    public static final int DIAMETER_NO_COMMON_APPLICATION = 5010;
    
    public static final int DIAMETER_UNABLE_TO_COMPLY = 5012;
    
}

---