Pfthb

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