inboxasyncimpl.java

《开发Nokia S40应用程序》源码（8-10章） 《开发Nokia S40应用程序》源码（8-10章）

package com.Series40Book;

import javax.wireless.messaging.*;
import javax.microedition.io.*;
import javax.microedition.rms.*;
import javax.microedition.lcdui.*;

public class InboxAsyncImpl
    implements Inbox, MessageListener {

  static final String rmsName = "InboxStore";
  RecordStore inbox;
  RecordEnumeration re;
  private int currentID;

  private boolean emptyBox;

  public InboxAsyncImpl () {
    emptyBox = false;
  }

  public boolean isBoxEmpty () {
    return emptyBox;
  }

  public void setupListener (String port)
                              throws Exception {
    MessageConnection sconn =
 (MessageConnection) Connector.open("sms://:" + port);
    sconn.setMessageListener (this);
  }

  public String firstMessage () throws Exception {
    inbox = RecordStore.openRecordStore(rmsName, true);
    re = inbox.enumerateRecords(null, null, true);
    return nextMessage();
  }

  public String nextMessage () throws Exception {

    emptyBox = false;

    if (re.hasNextElement()) {
      currentID = re.nextRecordId ();
      return new String(inbox.getRecord(currentID));
    } else {
      // Maybe the end has reached, loop back
      re.reset();
      if (re.hasNextElement()) {
        currentID = re.nextRecordId ();
        return new String (inbox.getRecord(currentID));
      } else {
        // No record in the enumeration
        emptyBox = true;
        return null;
      }
    }
  }

  public void deleteMessage () throws Exception {
    inbox.deleteRecord(currentID);
  }

  public void cleanUp () {
   try {
      if (re != null) {
        re.destroy();
      }
    } catch (Exception e) {
      // ignore all
    }

    try {
      if (inbox != null) {
        inbox.closeRecordStore();
      }
    } catch (Exception e) {
      // ignore all
    }
  }

  public void notifyIncomingMessage(MessageConnection c) {
    new Thread(new IncomingHandler(c)).start();
  }

}

class IncomingHandler implements Runnable {

  private MessageConnection sconn;

  public IncomingHandler (MessageConnection c) {
    sconn = c;
  }

  public synchronized void run () {
    try {
      Message msg = sconn.receive();
      if (msg instanceof TextMessage) {
        String msgText =
            ((TextMessage) msg).getPayloadText();
        RecordStore inbox =
                RecordStore.openRecordStore(
                      InboxAsyncImpl.rmsName, true);
        inbox.addRecord(msgText.getBytes(), 0,
                              msgText.length());
        inbox.closeRecordStore ();

        Alert a = new Alert ("Success",
                "New message received",
                   null, AlertType.INFO);
        Chat.display.setCurrent (a);

        Chat.processNewMessage();

      } else {
        // Discard non-text messages
        Alert a =
            new Alert ("Discarded",
                "Non-text message discarded",
                null, AlertType.WARNING);
        Chat.display.setCurrent (a);
      }
    } catch (Exception e) {
      e.printStackTrace ();
      Alert a = new Alert ("Error",
          "Message receiving error",
          null, AlertType.ERROR);
      Chat.display.setCurrent (a);
    }
  }
}