smshandler.java

J2ME MIDP_Example_Applications

//
// Copyright 2002 Nokia Corporation.
//
// THIS SOURCE CODE IS PROVIDED 'AS IS', WITH NO WARRANTIES WHATSOEVER,
// EXPRESS OR IMPLIED, INCLUDING ANY WARRANTY OF MERCHANTABILITY, FITNESS
// FOR ANY PARTICULAR PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE
// OR TRADE PRACTICE, RELATING TO THE SOURCE CODE OR ANY WARRANTY OTHERWISE
// ARISING OUT OF ANY PROPOSAL, SPECIFICATION, OR SAMPLE AND WITH NO
// OBLIGATION OF NOKIA TO PROVIDE THE LICENSEE WITH ANY MAINTENANCE OR
// SUPPORT. FURTHERMORE, NOKIA MAKES NO WARRANTY THAT EXERCISE OF THE
// RIGHTS GRANTED HEREUNDER DOES NOT INFRINGE OR MAY NOT CAUSE INFRINGEMENT
// OF ANY PATENT OR OTHER INTELLECTUAL PROPERTY RIGHTS OWNED OR CONTROLLED
// BY THIRD PARTIES
//
// Furthermore, information provided in this source code is preliminary,
// and may be changed substantially prior to final release. Nokia Corporation
// retains the right to make changes to this source code at any time,
// without notice. This source code is provided for informational
// purposes only.
//
// Nokia and Nokia Connecting People are registered trademarks of Nokia
// Corporation. Java and all Java-based marks are trademarks or registered
// trademarks of Sun Microsystems, Inc. Other product and company names
// mentioned herein may be trademarks or trade names of their respective owners.
//
// A non-exclusive, non-transferable, worldwide, limited license is hereby
// granted to the Licensee to download, print, reproduce and modify the
// source code. The licensee has the right to market, sell, distribute and
// make available the source code in original or modified form only when
// incorporated into the programs developed by the Licensee. No other
// license, express or implied, by estoppel or otherwise, to any other
// intellectual property rights is granted herein.
//


import java.io.*;
import java.util.*;


abstract class SmsHandler
    implements Runnable
{
    protected final Vector outgoingTextMessages = new Vector();

    protected IncomingTextMessageListener incomingListener;
    protected OutgoingTextMessageListener outgoingListener;
    protected String port = null;
    protected volatile boolean aborting = false;
    protected volatile int incomingMessagesPending = 0;


    protected SmsHandler()
    {
    }


    void init(IncomingTextMessageListener incomingListener,
        OutgoingTextMessageListener outgoingListener,
        String port)
    {
        this.incomingListener = incomingListener;
        this.outgoingListener = outgoingListener;
        this.port = port;

        // If we are able to open the server mode connection,
        // then start the thread that does listening + sending.
        if (openServerModeConnection())
        {
            Thread t = new Thread(this);
            t.start();
        }
    }


    public void run()
    {
        while (!aborting)
        {
            // 1. Wait if there is nothing to send or receive.
            synchronized (this)
            {
                if ((outgoingTextMessages.size() == 0) &&
                    (incomingMessagesPending == 0))
                {
                    try
                    {
                        wait(); // releases lock
                    }
                    catch (InterruptedException e)
                    {
                    }
                }
            }

            if (aborting)
            {
                break;
            }

            // 2. If there are any outgoing messages on the queue, then send one.
            while (outgoingTextMessages.size() > 0)
            {
                OutgoingTextMessage outgoing =
                    (OutgoingTextMessage) outgoingTextMessages.firstElement();

                doSend(outgoing);
                outgoingTextMessages.removeElementAt(0);
            }

            // 3. If there is an incoming message pending, then read it.
            while (incomingMessagesPending > 0)
            {
                doReceive();

                synchronized (this)
                {
                    incomingMessagesPending--;
                }
            }
        }
    }


    protected abstract boolean openServerModeConnection();


    protected abstract void doSend(OutgoingTextMessage outgoing);


    protected abstract void doReceive();


    void sendMessage(String[] addrs, String content)
    {
        for (int i = 0; i < addrs.length; i++)
        {
            if (addrs[i] != null)
            {
                OutgoingTextMessage outgoing =
                    new OutgoingTextMessage(addrs[i], content);

                outgoingTextMessages.addElement(outgoing);
            }
        }

        synchronized (this)
        {
            notify(); // wake up the sending thread
        }
    }


    void abort()
    {
        // Set the state to 'aborting'.

        aborting = true;
        synchronized (this)
        {
            notify(); // wake up the SmsHandler thread, to kill it
        }
    }
}