Merge remote-tracking branch 'origin/notification-service'

Android wrapper service is updated.

Change-Id: Iec12e1b9f48b60913e5915e9b3a8bfcf7c4bd891
Signed-off-by: cc <ch79.cho@samsung.com>
(cherry picked from commit 23d997e80a1d6f23da6c5e345ed77c30a1595861)
Reviewed-on: https://gerrit.iotivity.org/gerrit/11865
Tested-by: jenkins-iotivity <jenkins-iotivity@opendaylight.org>
Reviewed-by: Abitha Shankar <abitha.s@samsung.com>
Reviewed-by: Madan Lanka <lanka.madan@samsung.com>

diff --git a/service/notification/examples/android/NotiConsumerExample/app/build.gradle b/service/notification/examples/android/NotiConsumerExample/app/build.gradle
index 373dbf2..9023618 100755 (executable)
--- a/service/notification/examples/android/NotiConsumerExample/app/build.gradle
+++ b/service/notification/examples/android/NotiConsumerExample/app/build.gradle
@@ -16,6 +16,6 @@ android {
 dependencies {\r
     compile fileTree(include: ['*.jar'], dir: 'libs')\r
     compile 'com.android.support:appcompat-v7:23.0.1'\r
-    compile project(':iotivity-base-armeabi-debug')\r
-    compile project(':iotivity-armeabi-notification-service-debug')\r
+    compile project(':iotivity-base-armeabi-release')\r
+    compile project(':iotivity-armeabi-notification-service-release')\r
 }\r

diff --git a/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/ConsumerProxy.java b/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/ConsumerProxy.java
index eb0a6cb..175356d 100755 (executable)
--- a/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/ConsumerProxy.java
+++ b/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/ConsumerProxy.java
@@ -31,29 +31,33 @@ import org.iotivity.base.OcResourceHandle;
 import org.iotivity.base.PlatformConfig;\r
 import org.iotivity.base.QualityOfService;\r
 import org.iotivity.base.ServiceType;\r
+import org.iotivity.service.ns.common.NSException;\r
 import org.iotivity.service.ns.common.SyncInfo;\r
+import org.iotivity.service.ns.common.TopicsList;\r
 import org.iotivity.service.ns.consumer.ConsumerService;\r
 import org.iotivity.service.ns.consumer.Provider;\r
 \r
 import java.util.HashMap;\r
 \r
 public class ConsumerProxy\r
-    implements ConsumerService.OnProviderDiscoveredListner,\r
-    ConsumerService.OnProviderChangedListener,\r
+    implements ConsumerService.OnProviderDiscoveredListener,\r
+    Provider.OnProviderStateListener,\r
     Provider.OnMessageReceivedListner, Provider.OnSyncInfoReceivedListner\r
 {\r
-\r
     private static final String TAG = "NS_CONSUMER_PROXY";\r
 \r
     private Context mContext = null;\r
     private ConsumerService consumerService = null;\r
+    private boolean mAcceptor = false;\r
+    private Provider mProvider = null;\r
 \r
     private Handler mHandler = null;\r
 \r
     private static final int PROVIDER_DISCOVERED = 1;\r
-    private static final int SUBSCRIPTION_ACCEPTED = 2;\r
+    private static final int STATE_CHANGED = 2;\r
     private static final int MESSAGE_RECEIVED = 3;\r
     private static final int SYNCINFO_RECEIVED = 4;\r
+    private static final int TOPICS_RECEIVED = 5;\r
 \r
     public ConsumerProxy(Context context)\r
     {\r
@@ -68,6 +72,11 @@ public class ConsumerProxy
         this.mHandler = handler;\r
     }\r
 \r
+    public boolean getAcceptor()\r
+    {\r
+        return mAcceptor;\r
+    }\r
+\r
     private void configurePlatform()\r
     {\r
 \r
@@ -98,7 +107,7 @@ public class ConsumerProxy
         configurePlatform();\r
         try\r
         {\r
-            consumerService.Start(this, this);\r
+            consumerService.start(this);\r
         }\r
         catch (Exception e)\r
         {\r
@@ -110,7 +119,8 @@ public class ConsumerProxy
     {\r
         try\r
         {\r
-            consumerService.Stop();\r
+            consumerService.stop();\r
+            mProvider = null;\r
         }\r
         catch (Exception e)\r
         {\r
@@ -122,7 +132,7 @@ public class ConsumerProxy
     {\r
         try\r
         {\r
-            consumerService.EnableRemoteService(serverAddress);\r
+            consumerService.enableRemoteService(serverAddress);\r
         }\r
         catch (Exception e)\r
         {\r
@@ -134,112 +144,94 @@ public class ConsumerProxy
     {\r
         try\r
         {\r
-            consumerService.RescanProvider();\r
+            consumerService.rescanProvider();\r
         }\r
         catch (Exception e)\r
         {\r
             Log.e(TAG, "Exception: rescanProvider : " + e);\r
         }\r
     }\r
-\r
-    public Provider getProvider(String providerId)\r
-    {\r
-        Provider provider = null;\r
-        try\r
-        {\r
-            provider = consumerService.GetProvider(providerId);\r
-        }\r
-        catch (Exception e)\r
-        {\r
-            Log.e(TAG, "Exception: getProvider : " + e);\r
-        }\r
-        return provider;\r
-    }\r
-\r
-    public void subscribe(String providerId)\r
+    public void getTopicsList()\r
     {\r
-        try\r
+        if (mProvider != null)\r
         {\r
-            Provider provider = getProvider(providerId);\r
-            if (provider != null)\r
-                provider.Subscribe();\r
-            else\r
-                Log.e(TAG, "providerID is Null : ");\r
+            try\r
+            {\r
+                TopicsList topicsList = mProvider.getTopicList();\r
+            }\r
+            catch (Exception e)\r
+            {\r
+                Log.e(TAG, "Exception: getTopicsList : " + e);\r
+            }\r
         }\r
-        catch (Exception e)\r
+        else\r
         {\r
-            Log.e(TAG, "Exception: Subscribe : " + e);\r
+            Log.e(TAG, "getTopicsList Provider NULL");\r
         }\r
     }\r
-\r
-    public void unsubscribe(String providerId)\r
+    public void updateTopicList(TopicsList topicsList)\r
     {\r
-        try\r
+        if (mProvider != null)\r
         {\r
-            Provider provider = getProvider(providerId);\r
-            if (provider != null)\r
-                provider.Unsubscribe();\r
-            else\r
-                Log.e(TAG, "providerID is Null : ");\r
+            try\r
+            {\r
+                mProvider.updateTopicList(topicsList);\r
+            }\r
+            catch (Exception e)\r
+            {\r
+                Log.e(TAG, "Exception: updateTopicList : " + e);\r
+            }\r
         }\r
-        catch (Exception e)\r
+        else\r
         {\r
-            Log.e(TAG, "Exception: Unsubscribe : " + e);\r
+            Log.e(TAG, "updateTopicList Provider NULL");\r
         }\r
     }\r
-\r
-    public void sendSyncInfo(String providerId, long messageId, SyncInfo.SyncType syncType)\r
+    @Override\r
+    public void onProviderDiscovered(Provider provider)\r
     {\r
-        try\r
-        {\r
-            Provider provider = getProvider(providerId);\r
-            if (provider != null)\r
-                provider.SendSyncInfo(messageId, syncType);\r
-            else\r
-                Log.e(TAG, "providerID is Null : ");\r
-        }\r
-        catch (Exception e)\r
+        Log.i(TAG, "onProviderDiscovered");\r
+        if (provider == null)\r
         {\r
-            Log.e(TAG, "Exception: SendSyncInfo : " + e);\r
+            Log.e(TAG, "providerID is Null  ");\r
+            return;\r
         }\r
-    }\r
-\r
-    public void setListener(String providerId)\r
-    {\r
+        mProvider = provider;\r
+        Log.i(TAG, "Provider ID: " + provider.getProviderId() );\r
+        Message msg = mHandler.obtainMessage(PROVIDER_DISCOVERED,\r
+                                             "Provider Discovered Id: " + provider.getProviderId());\r
+        mHandler.sendMessage(msg);\r
         try\r
         {\r
-            Provider provider = getProvider(providerId);\r
-            if (provider != null)\r
-                provider.SetListener(this, this);\r
+            Log.i(TAG, "setListeners to Discovered Provider");\r
+            provider.setListener(this, this, this);\r
+            Log.i(TAG, "setListeners done");\r
+            if (! provider.isSubscribed())\r
+            {\r
+                Log.i(TAG, "Provider not subscribed. Acceptor is Consumer");\r
+                mAcceptor = false;\r
+                provider.subscribe();\r
+            }\r
             else\r
-                Log.e(TAG, "providerID is Null : ");\r
+            {\r
+                Log.i(TAG, "Provider is already subscribed. Acceptor is Provider");\r
+                mAcceptor = true;\r
+            }\r
         }\r
         catch (Exception e)\r
         {\r
-            Log.e(TAG, "Exception: SetListener : " + e);\r
+            Log.e(TAG, "Exception : " + e);\r
         }\r
     }\r
 \r
     @Override\r
-    public void onProviderDiscovered(Provider provider)\r
+    public void onProviderStateReceived(Provider.ProviderState state)\r
     {\r
-        Log.i(TAG, "onProviderDiscovered");\r
+        Log.i(TAG, "onProviderStateReceived");\r
 \r
-        Log.i(TAG, "Provider ID: " + provider.getProviderId() );\r
-        Message msg = mHandler.obtainMessage(PROVIDER_DISCOVERED, provider.getProviderId());\r
+        Log.i(TAG, "Provider state: " + state );\r
+        Message msg = mHandler.obtainMessage(STATE_CHANGED, "Provider state: " + state);\r
         mHandler.sendMessage(msg);\r
-        subscribe(provider.getProviderId());\r
-    }\r
-\r
-    @Override\r
-    public void onProviderChanged(Provider provider , ConsumerService.Response response)\r
-    {\r
-        Log.i(TAG, "onSubscriptionAccepted");\r
-\r
-        Log.i(TAG, "Provider ID: " + provider.getProviderId() );\r
-        Message msg = mHandler.obtainMessage(SUBSCRIPTION_ACCEPTED, provider.getProviderId());\r
-        mHandler.sendMessage(msg);\r
-        setListener(provider.getProviderId());\r
     }\r
 \r
     @Override\r
@@ -250,14 +242,25 @@ public class ConsumerProxy
         Log.i(TAG, "Message Id: " + message.getMessageId());\r
         Log.i(TAG, "Message title: " + message.getTitle());\r
         Log.i(TAG, "Message Content: " + message.getContentText());\r
+        Log.i(TAG, "Message Topic: " + message.getTopic());\r
         Log.i(TAG, "Message Source: " + message.getSourceName());\r
 \r
         Message msg = mHandler.obtainMessage(MESSAGE_RECEIVED,\r
-                                             "Message Id: " + message.getMessageId() +\r
-                                             " / Message title: " + message.getTitle() +\r
-                                             " / Message Content: " + message.getContentText() +\r
-                                             " / Message Source: " + message.getSourceName() );\r
+                                             "Message Id: " + message.getMessageId() + "\n" +\r
+                                             "Message title: " + message.getTitle() + "\n" +\r
+                                             "Message Content: " + message.getContentText() + "\n" +\r
+                                             "Message Topic: " + message.getTopic() + "\n" +\r
+                                             "Message Source: " + message.getSourceName() );\r
         mHandler.sendMessage(msg);\r
+        try\r
+        {\r
+            Log.i(TAG, "send READ syncInfo");\r
+            mProvider.sendSyncInfo(message.getMessageId(), SyncInfo.SyncType.READ);\r
+        }\r
+        catch (Exception e)\r
+        {\r
+            Log.e(TAG, "Exception : " + e);\r
+        }\r
     }\r
 \r
     @Override\r
@@ -268,8 +271,8 @@ public class ConsumerProxy
         Log.i(TAG, "Sync Id: " + sync.getMessageId());\r
         Log.i(TAG, "Sync STATE: " + sync.getState());\r
         Message msg = mHandler.obtainMessage(SYNCINFO_RECEIVED,\r
-                                             "Sync Id: " + sync.getMessageId() +\r
-                                             " / Sync STATE: " + sync.getState());\r
+                                             "Sync Id: " + sync.getMessageId() + "\n" +\r
+                                             "Sync STATE: " + sync.getState());\r
         mHandler.sendMessage(msg);\r
     }\r
 }\r

diff --git a/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/MainActivity.java b/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/MainActivity.java
index 01e2a99..7d9e463 100755 (executable)
--- a/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/MainActivity.java
+++ b/service/notification/examples/android/NotiConsumerExample/app/src/main/java/com/sec/noticonsumerexample/MainActivity.java
@@ -32,14 +32,18 @@ import android.widget.EditText;
 import android.widget.TextView;\r
 import android.widget.Toast;\r
 \r
+import org.iotivity.service.ns.common.TopicsList;\r
+\r
 public class MainActivity extends AppCompatActivity\r
 {\r
-\r
     private final String TAG = "NS_MAIN_ACTIVITY";\r
 \r
     private Button btnStart;\r
     private Button btnStop;\r
     private Button btnRescan;\r
+    private Button btnEnableRemoteService;\r
+    private Button btnGetTopicList;\r
+    private Button btnUpdateTopicList;\r
     private static TextView TvLog;\r
 \r
     private boolean isStarted = false;\r
@@ -48,9 +52,10 @@ public class MainActivity extends AppCompatActivity
     private ConsumerProxy mConsumerProxy = null;\r
 \r
     private static final int PROVIDER_DISCOVERED = 1;\r
-    private static final int SUBSCRIPTION_ACCEPTED = 2;\r
+    private static final int STATE_CHANGED = 2;\r
     private static final int MESSAGE_RECEIVED = 3;\r
     private static final int SYNCINFO_RECEIVED = 4;\r
+    private static final int TOPICS_RECEIVED = 5;\r
 \r
     public static Handler mHandler = new Handler()\r
     {\r
@@ -64,16 +69,16 @@ public class MainActivity extends AppCompatActivity
                         String providerId = (String) msg.obj;\r
                         if (providerId != null)\r
                         {\r
-                            TvLog.append("Discovered : ProviderID: " + providerId + "\n");\r
+                            TvLog.append( providerId + "\n");\r
                         }\r
                         break;\r
                     }\r
-                case SUBSCRIPTION_ACCEPTED:\r
+                case STATE_CHANGED:\r
                     {\r
-                        String providerId = (String) msg.obj;\r
-                        if (providerId != null)\r
+                        String state = (String) msg.obj;\r
+                        if (state != null)\r
                         {\r
-                            TvLog.append("Subscription Accepted : ProviderID: " + providerId + "\n");\r
+                            TvLog.append( state + "\n");\r
                         }\r
                         break;\r
                     }\r
@@ -82,7 +87,7 @@ public class MainActivity extends AppCompatActivity
                         String message = (String) msg.obj;\r
                         if (message != null)\r
                         {\r
-                            TvLog.append("Message Received : " + message + "\n");\r
+                            TvLog.append( message + "\n");\r
                         }\r
                         break;\r
                     }\r
@@ -91,7 +96,7 @@ public class MainActivity extends AppCompatActivity
                         String sync = (String) msg.obj;\r
                         if (sync != null)\r
                         {\r
-                            TvLog.append("SyncInfo Received : " + sync + "\n");\r
+                            TvLog.append( sync + "\n");\r
                         }\r
                         break;\r
                     }\r
@@ -122,12 +127,18 @@ public class MainActivity extends AppCompatActivity
         btnStart = (Button) findViewById(R.id.BtnStart);\r
         btnStop = (Button) findViewById(R.id.BtnStop);\r
         btnRescan = (Button) findViewById(R.id.BtnRescan);\r
+        btnEnableRemoteService = (Button) findViewById(R.id.BtnEnableRemoteService);\r
+        btnGetTopicList = (Button) findViewById(R.id.BtnGetTopicList);\r
+        btnUpdateTopicList = (Button) findViewById(R.id.BtnUpdateTopicList);\r
 \r
         TvLog = (TextView) findViewById(R.id.TvLog);\r
 \r
         btnStart.setOnClickListener(mClickListener);\r
         btnStop.setOnClickListener(mClickListener);\r
         btnRescan.setOnClickListener(mClickListener);\r
+        btnEnableRemoteService.setOnClickListener(mClickListener);\r
+        btnGetTopicList.setOnClickListener(mClickListener);\r
+        btnUpdateTopicList.setOnClickListener(mClickListener);\r
 \r
         mConsumerProxy = new ConsumerProxy(getApplicationContext());\r
         mConsumerProxy.setHandler(mHandler);\r
@@ -136,7 +147,7 @@ public class MainActivity extends AppCompatActivity
     @Override\r
     protected void onDestroy()\r
     {\r
-        if(isStarted)\r
+        if (isStarted)\r
             mConsumerProxy.stopNotificationConsumer();\r
         super.onDestroy();\r
     }\r
@@ -152,7 +163,6 @@ public class MainActivity extends AppCompatActivity
         {\r
             switch (v.getId())\r
             {\r
-\r
                 case R.id.BtnStart:\r
                     {\r
                         if (isStarted == false)\r
@@ -174,29 +184,65 @@ public class MainActivity extends AppCompatActivity
                     {\r
                         if (isStarted == false)\r
                         {\r
-                            Log.e(TAG, "Fail to stop service");\r
+                            Log.e(TAG, "Fail to stop service. Service has not been started");\r
                             break;\r
                         }\r
-\r
+                        TvLog.append("Stop NS-Consumer\n");\r
                         mConsumerProxy.stopNotificationConsumer();\r
                         isStarted = false;\r
-\r
-                        TvLog.append("Stop NS-Consumer\n");\r
                     }\r
                     break;\r
                 case R.id.BtnRescan:\r
                     {\r
                         if (isStarted == false)\r
                         {\r
-                            Log.e(TAG, "Fail to rescan");\r
+                            Log.e(TAG, "Fail to rescan. Service has not been started");\r
                             break;\r
                         }\r
 \r
-                        mConsumerProxy.rescanProvider();\r
                         TvLog.append("Rescan NS-Consumer\n");\r
+                        mConsumerProxy.rescanProvider();\r
                     }\r
                     break;\r
+                case R.id.BtnEnableRemoteService:\r
+                    {\r
+                        if (isStarted == false)\r
+                        {\r
+                            Log.e(TAG, "Fail to Enable RemoteService. Service has not been started");\r
+                            break;\r
+                        }\r
+                        TvLog.append("EnableRemoteService NS-Consumer\n");\r
 \r
+                        //TODO: Update to read the serverAddress from UI\r
+                        String serverAddress = new String();\r
+                        mConsumerProxy.enableRemoteService(serverAddress);\r
+                    }\r
+                    break;\r
+                case R.id.BtnGetTopicList:\r
+                    {\r
+                        if (isStarted == false)\r
+                        {\r
+                            Log.e(TAG, "Fail to GetTopicList. Service has not been started");\r
+                            break;\r
+                        }\r
+                        TvLog.append("GetTopicList NS-Consumer\n");\r
+                        mConsumerProxy.getTopicsList();\r
+                    }\r
+                    break;\r
+                case R.id.BtnUpdateTopicList:\r
+                    {\r
+                        if (isStarted == false)\r
+                        {\r
+                            Log.e(TAG, "Fail to UpdateTopicList. Service has not been started");\r
+                            break;\r
+                        }\r
+                        TvLog.append("UpdateTopicList NS-Consumer\n");\r
+\r
+                        //TODO: Update to read the TopicsList from UI\r
+                        TopicsList topicsList = new TopicsList();\r
+                        mConsumerProxy.updateTopicList(topicsList);\r
+                    }\r
+                    break;\r
             }\r
         }\r
     };\r

diff --git a/service/notification/examples/android/NotiConsumerExample/app/src/main/res/layout/activity_main.xml b/service/notification/examples/android/NotiConsumerExample/app/src/main/res/layout/activity_main.xml
index 5cc23da..2a93adc 100755 (executable)
--- a/service/notification/examples/android/NotiConsumerExample/app/src/main/res/layout/activity_main.xml
+++ b/service/notification/examples/android/NotiConsumerExample/app/src/main/res/layout/activity_main.xml
@@ -46,6 +46,24 @@
                 android:layout_width="match_parent"\r
                 android:id="@+id/BtnRescan"\r
                 android:text="RESCAN"/>\r
+            <Button\r
+                android:layout_gravity="center_vertical|center_horizontal"\r
+                android:layout_height="0dp"\r
+                android:layout_width="match_parent"\r
+                android:id="@+id/BtnEnableRemoteService"\r
+                android:text="Enable Remote Service"/>\r
+            <Button\r
+                android:layout_gravity="center_vertical|center_horizontal"\r
+                android:layout_height="0dp"\r
+                android:layout_width="match_parent"\r
+                android:id="@+id/BtnGetTopicList"\r
+                android:text="Get TopicList"/>\r
+            <Button\r
+                android:layout_gravity="center_vertical|center_horizontal"\r
+                android:layout_height="0dp"\r
+                android:layout_width="match_parent"\r
+                android:id="@+id/BtnUpdateTopicList"\r
+                android:text="Update TopicList"/>\r
         </LinearLayout>\r
 \r
         <LinearLayout\r

diff --git a/service/notification/examples/android/NotiConsumerExample/iotivity-armeabi-notification-service-debug/build.gradle b/service/notification/examples/android/NotiConsumerExample/iotivity-armeabi-notification-service-release/build.gradle
similarity index 84%
rename from service/notification/examples/android/NotiConsumerExample/iotivity-armeabi-notification-service-debug/build.gradle
rename to service/notification/examples/android/NotiConsumerExample/iotivity-armeabi-notification-service-release/build.gradle
index ff5889d..0cc2c63 100755 (executable)
--- a/service/notification/examples/android/NotiConsumerExample/iotivity-armeabi-notification-service-debug/build.gradle
+++ b/service/notification/examples/android/NotiConsumerExample/iotivity-armeabi-notification-service-release/build.gradle
@@ -1,2 +1,2 @@
 configurations.maybeCreate("default")
-artifacts.add("default", file('iotivity-armeabi-notification-service-debug.aar'))
\ No newline at end of file
+artifacts.add("default", file('iotivity-armeabi-notification-service-release.aar'))
\ No newline at end of file

diff --git a/service/notification/examples/android/NotiConsumerExample/iotivity-base-armeabi-debug/build.gradle b/service/notification/examples/android/NotiConsumerExample/iotivity-base-armeabi-debug/build.gradle
deleted file mode 100755 (executable)
index e09bcd6..0000000
--- a/service/notification/examples/android/NotiConsumerExample/iotivity-base-armeabi-debug/build.gradle
+++ /dev/null
@@ -1,2 +0,0 @@
-configurations.maybeCreate("default")
-artifacts.add("default", file('iotivity-base-armeabi-debug.aar'))
\ No newline at end of file

diff --git a/service/notification/examples/android/NotiConsumerExample/iotivity-base-armeabi-release/build.gradle b/service/notification/examples/android/NotiConsumerExample/iotivity-base-armeabi-release/build.gradle
new file mode 100755 (executable)
index 0000000..a4078ab
--- /dev/null
+++ b/service/notification/examples/android/NotiConsumerExample/iotivity-base-armeabi-release/build.gradle
@@ -0,0 +1,2 @@
+configurations.maybeCreate("default")
+artifacts.add("default", file('iotivity-base-armeabi-release.aar'))
\ No newline at end of file

diff --git a/service/notification/examples/android/NotiConsumerExample/settings.gradle b/service/notification/examples/android/NotiConsumerExample/settings.gradle
index 68c1980..836b36e 100755 (executable)
--- a/service/notification/examples/android/NotiConsumerExample/settings.gradle
+++ b/service/notification/examples/android/NotiConsumerExample/settings.gradle
@@ -1 +1 @@
-include ':app', ':iotivity-base-armeabi-debug', ':iotivity-armeabi-notification-service-debug'
\ No newline at end of file
+include ':app', ':iotivity-base-armeabi-release', ':iotivity-armeabi-notification-service-release'
\ No newline at end of file

diff --git a/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/MainActivity.java b/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/MainActivity.java
index b2772bb..a5072f6 100755 (executable)
--- a/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/MainActivity.java
+++ b/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/MainActivity.java
@@ -41,7 +41,7 @@ import org.iotivity.service.ns.common.MediaContents;
 public class MainActivity extends AppCompatActivity {\r
 \r
     private final String TAG = "NS_MAIN_ACTIVITY";\r
-    private static final int MESSAGE_SUBSCRIPTION = 1;\r
+    private static final int CONSUMER_SUBSCRIBED = 1;\r
     private static final int MESSAGE_SYNC = 2;\r
     private static final int MESSAGE_NOTIFICATION = 3;\r
 \r
@@ -68,16 +68,16 @@ public class MainActivity extends AppCompatActivity {
         @Override\r
         public void handleMessage(Message msg) {\r
             switch (msg.what) {\r
-                case MESSAGE_SUBSCRIPTION:\r
-                    String subscriber = (String) msg.obj;\r
-                    if(subscriber != null)\r
-                        TvLog.append("Subscriber IP(" + ++subCnt + "): " + subscriber + "\n");\r
+                case CONSUMER_SUBSCRIBED:\r
+                    String ConsumerId = (String) msg.obj;\r
+                    if(ConsumerId != null)\r
+                        TvLog.append("Consumer Subscibed: " + ConsumerId + "\n");\r
                     break;\r
 \r
                 case MESSAGE_SYNC:\r
                     String sync = (String) msg.obj;\r
                     if(sync != null)\r
-                        TvLog.append("Sync-Read(Msg ID: " + sync + ")\n");\r
+                        TvLog.append("SyncInfo Received :" + sync + "\n");\r
                     break;\r
 \r
                 default:\r

diff --git a/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/ProviderProxy.java b/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/ProviderProxy.java
index 789afe1..0c5aada 100755 (executable)
--- a/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/ProviderProxy.java
+++ b/service/notification/examples/android/NotiProviderExample/app/src/main/java/com/sec/notiproviderexample/ProviderProxy.java
@@ -23,7 +23,7 @@
 package com.sec.notiproviderexample;\r
 \r
 import android.content.Context;\r
-import android.os.Handler;\r
+import android.os.*;\r
 import android.util.Log;\r
 import android.widget.Toast;\r
 \r
@@ -33,6 +33,7 @@ import org.iotivity.base.OcResourceHandle;
 import org.iotivity.base.PlatformConfig;\r
 import org.iotivity.base.QualityOfService;\r
 import org.iotivity.base.ServiceType;\r
+import org.iotivity.service.ns.common.Message;\r
 import org.iotivity.service.ns.provider.*;\r
 import org.iotivity.service.ns.common.*;\r
 \r
@@ -40,7 +41,7 @@ import org.iotivity.service.ns.common.*;
 import java.util.HashMap;\r
 \r
 public class ProviderProxy\r
-        implements ProviderService.OnSubscriptionListener, ProviderService.OnSyncInfoListener{\r
+        implements ProviderService.OnConsumerSubscribedListener, ProviderService.OnMessageSynchronizedListener{\r
 \r
     private static final String TAG = "NS_PROVIDER_PROXY";\r
 \r
@@ -51,7 +52,7 @@ public class ProviderProxy
 \r
     private Handler mHandler = null;\r
 \r
-    private static final int MESSAGE_SUBSCRIPTION = 1;\r
+    private static final int CONSUMER_SUBSCRIBED = 1;\r
     private static final int MESSAGE_SYNC = 2;\r
 \r
     private static final int SYNC_READ = 0;\r
@@ -97,7 +98,7 @@ public class ProviderProxy
         Log.i(TAG, "Start ProviderService -IN");\r
         configurePlatform();\r
         try{\r
-            int result =  ioTNotification.Start(policy, this, this);\r
+            int result =  ioTNotification.start(this, this, policy, "Info");\r
             Log.i(TAG, "Notification Start: " + result);\r
         }\r
         catch(Exception e){\r
@@ -115,7 +116,7 @@ public class ProviderProxy
             Log.e(TAG, "Exception: stopping presence when terminating NS server: " + e);\r
         }\r
         try{\r
-            int result =  ioTNotification.Stop();\r
+            int result =  ioTNotification.stop();\r
             Log.i(TAG, "Notification Stop: " + result);\r
         }\r
         catch(Exception e){\r
@@ -129,7 +130,7 @@ public class ProviderProxy
         Log.i(TAG, "SendMessage ProviderService - IN");\r
 \r
         try{\r
-            int result =  ioTNotification.SendMessage(notiMessage);\r
+            int result =  ioTNotification.sendMessage(notiMessage);\r
             Log.i(TAG, "Notification Send Message: " + result);\r
         }\r
         catch(Exception e){\r
@@ -151,7 +152,7 @@ public class ProviderProxy
             if(msgMap.get(messageId) == SYNC_UNREAD)\r
             {\r
                 try{\r
-                    ioTNotification.SendSyncInfo(messageId,syncType );\r
+                    ioTNotification.sendSyncInfo(messageId, syncType);\r
                     Log.i(TAG, "Notification Sync " );\r
                 }\r
                 catch(Exception e) {\r
@@ -166,7 +167,7 @@ public class ProviderProxy
     public void EnableRemoteService(String servAdd) {\r
         Log.i(TAG, "EnableRemoteService ProviderService - IN");\r
         try{\r
-            int result = ioTNotification.EnableRemoteService(servAdd);\r
+            int result = ioTNotification.enableRemoteService(servAdd);\r
             Log.i(TAG, "Notification EnableRemoteService: "+ result );\r
         }\r
         catch(Exception e) {\r
@@ -178,7 +179,7 @@ public class ProviderProxy
     public void DisableRemoteService(String servAdd) {\r
         Log.i(TAG, "DisableRemoteService ProviderService - IN");\r
         try{\r
-            int result = ioTNotification.DisableRemoteService(servAdd);\r
+            int result = ioTNotification.disableRemoteService(servAdd);\r
             Log.i(TAG, "Notification DisableRemoteService: "+ result );\r
         }\r
         catch(Exception e) {\r
@@ -191,7 +192,7 @@ public class ProviderProxy
     {\r
         Log.i(TAG,"AcceptSubscription ProviderService - IN");\r
         try{\r
-            int result = consumer.AcceptSubscription(consumer, accepted);\r
+            int result = consumer.acceptSubscription(accepted);\r
             Log.i(TAG, "Notification AcceptSubscription: "+result );\r
         }\r
         catch(Exception e) {\r
@@ -204,12 +205,18 @@ public class ProviderProxy
     public void onConsumerSubscribed(Consumer consumer) {\r
         Log.i(TAG, "onConsumerSubscribed - IN");\r
         AcceptSubscription(consumer, true);\r
+        android.os.Message msg = mHandler.obtainMessage(CONSUMER_SUBSCRIBED,\r
+                "Consumer Id: " + consumer.getConsumerId()  );\r
+        mHandler.sendMessage(msg);\r
         Log.i(TAG, "onConsumerSubscribed - OUT");\r
     }\r
 \r
     @Override\r
     public void onMessageSynchronized(SyncInfo syncInfo) {\r
         Log.i(TAG, "Received SyncInfo with messageID: "+syncInfo.getMessageId());\r
+        android.os.Message msg = mHandler.obtainMessage(MESSAGE_SYNC,\r
+                "Message Id: " + syncInfo.getMessageId()  );\r
+        mHandler.sendMessage(msg);\r
     }\r
 \r
     public HashMap<String, Integer> getMsgMap() {\r