import java.io.IOException;

import javax.microedition.io.Connector;
import javax.microedition.midlet.MIDlet;
import javax.microedition.midlet.MIDletStateChangeException;
import javax.wireless.messaging.Message;
import javax.wireless.messaging.MessageConnection;
import javax.wireless.messaging.MessageListener;
import javax.wireless.messaging.TextMessage;

public class ReceiveCBS extends MIDlet implements MessageListener{
    /** 用于接收消息 */
    private MessageConnection mcbs;
    
	public ReceiveCBS() {
		super();
		// TODO 自動生成構造函數存根
	}

	protected void startApp() throws MIDletStateChangeException {
		//啟動消息監聽
        try {
        	mcbs = (MessageConnection)Connector.open
                    ("cbs://:1234"); //1234為小區廣播標識
            //注冊消息監聽器.
        	mcbs.setMessageListener(this);
        } catch (Exception e) {
            System.out.println("不能進行小區廣播接收：" + e.toString());
        }
	}

	protected void pauseApp() {
		// TODO 自動生成方法存根

	}

	protected void destroyApp(boolean arg0)
		throws MIDletStateChangeException {
		// TODO 自動生成方法存根

	}

    /**
     * 當有消息到達時執行該函數
     */
    public void notifyIncomingMessage(MessageConnection mc) {
        //在獨立的線程中接收消息
        new Thread() {
            public void run() {
                Message msg=null;
                try {
                    msg = mcbs.receive();
                } catch (IOException e) {
                    //處理讀取消息時發生的錯誤
                    System.out.println("讀取消息時發生異常：" +
                            e.toString());
                    return;
                }
                //處理讀取的文本消息
                if(msg == null) {
                	return;
                }
                System.out.println("讀取消息...");
                if(msg instanceof TextMessage){
                    TextMessage tmsg = (TextMessage)msg;
                    System.out.println("接收到一條消息");
                    System.out.println("	接收時間：" + 
                    		tmsg.getTimestamp());
                    System.out.println("	消息發送方：" + 
                    		tmsg.getAddress());
                    System.out.println("	消息內容：" + 
                    		tmsg.getPayloadText());
                } else {
                	//二進制消息處理
                }
            }
        }.start();
    }
}