Wsrtjtyk

I have a ContentObserver listening content://sms/inbox. When I send long SMS message from one Android emulator to another Android emulator, this ContentObserver fires multiply (depending on the number of short sms messages in the long sms message). I need to concatenate short messages in one long message, but I have no a feature to decide were these messages sent as parts of one long message or they are independent succesive short messages. It seems available cursor columns does not contain such a feature at all:

0 = "_id"

1 = "thread_id"

2 = "address"

3 = "person"

4 = "date"

5 = "date_sent"

6 = "protocol"

7 = "read"

8 = "status"

9 = "type"

10 = "reply_path_present"

11 = "subject"

12 = "body"

13 = "service_center"

14 = "locked"

15 = "sub_id"

16 = "error_code"

17 = "creator"

18 = "seen"

As I know there is a way to do desired concatenation thru receiver and "pdus". Is it the only way to proceed?

P.S. I have found that real (not emulator) Android SMS client does not keep a long message as series of short messages. It concatenates short messages in storeMessage method and saves them as a whole long message in database. So the question is why Android emulator SMS client is differ from the real one!?

UPDATE:
SmsObserverclass:

public class SMSObserver1 extends ContentObserver {

    private Context context;

    private SmsListener listener;



    public SMSObserver(Context context, Handler handler, SmsListener listener) {

        super(handler);

        this.context = context;

        this.listener = listener;

    }



    @Override

    public void onChange(boolean selfChange) {

        super.onChange(selfChange);

        Uri mUri = Uri.parse("content://sms");

        Cursor mCursor = context.getContentResolver().query(mUri, null, null, null, null);

        if (mCursor != null && mCursor.moveToNext()) {

            SmsEntity entity = null;

            int type = mCursor.getInt(mCursor.getColumnIndex("type"));//now we need to decide SMS message is sent or received

            if (type == 1) //it's received SMS

                entity = getSMS(true);

            else if (type == 2) //it's sent SMS

                entity = getSMS(false);

            mCursor.close();

            if (entity != null)

                listener.addSms(entity);

        }

    }



    private SmsEntity getSMS(boolean isIncoming) {

        SmsEntity entity = null;

        Uri uri = Uri.parse(isIncoming ? "content://sms/inbox" : "content://sms/sent");

        Cursor cursor = context.getContentResolver().query(uri, null,null, null, null);

        if (cursor != null && cursor.moveToNext()) {

            entity = printSms(cursor, isIncoming);

            cursor.close();

        }

        return entity;

    }



    private SmsEntity printSms(Cursor cursor, boolean isIncoming){

        int type = cursor.getInt(cursor.getColumnIndex("type"));

        long msg_id= cursor.getLong(cursor.getColumnIndex("_id"));

        String phone = cursor.getString(cursor.getColumnIndex("address"));

        long dateVal = cursor.getLong(cursor.getColumnIndex("date"));

        String body = cursor.getString(cursor.getColumnIndex("body"));

        Date date = new Date(dateVal);



        String str = (isIncoming ? "Received" : "Sent") + " SMS: n phone is: " + phone;

        str +="n SMS type is: " + type;

        str +="n SMS time stamp is:" + date;

        str +="n SMS body is: " + body;

        str +="n id is : " + msg_id;

        Log.v("Debug", str);



        return new SmsEntity(msg_id, dateVal, true, isIncoming, phone, body);

    }

}

Registering/unregistering happens in onResume/onPause callbacks of Fragment:

@Override

public void onPause() {

    super.onPause();

    unregisterContentObserver();

}



public void unregisterContentObserver() {

    if (mSmsObserver != null) {

        try {

            getActivity().getContentResolver().unregisterContentObserver(mSmsObserver);

        } catch (IllegalStateException ise) {

            Timber.w(ise.getMessage());

        } finally {

            mSmsObserver = null;

        }

    }

}



@Override

public void onResume() {

    super.onResume();

    registerContentObserver();

}



private void registerContentObserver() {

    mSmsObserver = new SMSObserver(getActivity(), new Handler(),this);

    getActivity().getContentResolver().registerContentObserver(Uri.parse("content://sms/inbox"), true, mSmsObserver);//To track an incoming SMS only

}