destinationtable.java

短信短消息SMPP开发的JAVA API最新版本。

/*
 * Java SMPP API
 * Copyright (C) 1998 - 2002 by Oran Kelly
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 * 
 * This library 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
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 * A copy of the LGPL can be viewed at http://www.gnu.org/copyleft/lesser.html
 * Java SMPP API author: [e-mail]
 * Java SMPP API Homepage: http://smppapi.sourceforge.net/
 * $Id: DestinationTable.java,v 1.5 2004/10/09 22:02:41 orank Exp $
 */
package ie.omk.smpp.message;

import ie.omk.smpp.Address;
import ie.omk.smpp.util.SMPPIO;

import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.ListIterator;

import org.apache.commons.logging.LogFactory;

public class DestinationTable
{
    private ArrayList dests = null;

    private int length = 0;

    DestinationTable()
    {
	dests = new ArrayList();
    }

    synchronized void add(Address addr)
    {
	dests.add(addr);
	length += addr.getLength() + 1; // don't forget the dest type flag!
    }

    synchronized void add(String distList)
    {
	dests.add(distList);
	length += distList.length() + 2; // nul byte plus dest type flag
    }

    public synchronized void remove(Address addr)
    {
	int i = dests.indexOf(addr);
	if (i > -1)
	    length -= ((Address)dests.remove(i)).getLength() + 1;
    }

    public synchronized void remove(String distList)
    {
	int i = dests.indexOf(distList);
	if (i > -1)
	    length -= ((String)dests.remove(i)).length() + 2;
    }

    public Iterator iterator()
    {
	return (Collections.unmodifiableList(dests).iterator());
    }

    public ListIterator listIterator()
    {
	return (Collections.unmodifiableList(dests).listIterator());
    }

    public synchronized Object clone()
    {
	DestinationTable dt = new DestinationTable();
	dt.dests = (ArrayList)this.dests.clone();
	return (dt);
    }

    public synchronized int getLength()
    {
	return (length);
    }

    public int size()
    {
	return (dests.size());
    }

    public synchronized void writeTo(OutputStream out)
	throws java.io.IOException
    {
	Iterator i = dests.iterator();
	while (i.hasNext()) {
	    Object o = i.next();
	    if (o instanceof Address) {
		SMPPIO.writeInt(1, 1, out);
		((Address)o).writeTo(out);
	    } else {
		SMPPIO.writeInt(2, 1, out);
		SMPPIO.writeCString((String)o, out);
	    }
	}
    }

    public synchronized void readFrom(byte[] table, int offset, int count)
    {
	for (int i = 0; i < count; i++) {
	    int type = SMPPIO.bytesToInt(table, offset++, 1);
	    if (type == 1) {
		// SME address..
		Address a = new Address();
		a.readFrom(table, offset);
		offset += a.getLength();
		dests.add(a);
	    } else if (type == 2) {
		// Distribution list name
		String d = SMPPIO.readCString(table, offset);
		offset += d.length() + 1;
		dests.add(d);
	    } else {
		LogFactory.getLog(DestinationTable.class)
		    .warn("Unidentified destination type on input.");
	    }
	}

	calculateLength();
    }

    private void calculateLength()
    {
	length = 0;

	Iterator i = dests.iterator();
	while (i.hasNext()) {
	    Object o = i.next();
	    length++;	    // For the destination type flag
	    if (o instanceof Address)
		length += ((Address)o).getLength();
	    else
		length += ((String)o).length() + 1;
	}
    }
}