X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=service%2Fnotification%2Fandroid%2Fnotification-service%2Fsrc%2Fmain%2Fjava%2Forg%2Fiotivity%2Fservice%2Fns%2Fconsumer%2FConsumerService.java;h=50e49803277378259689e179bd5aa00f3138caa3;hb=3c093548382bb2542c87a67e6e5fa32552c29cb3;hp=58bf57a7d870adeb8ad6f8a1ba23d879e8bae48c;hpb=edcfc3d2329da7b914771c0dcff5f42c9b74fd93;p=platform%2Fupstream%2Fiotivity.git

diff --git a/service/notification/android/notification-service/src/main/java/org/iotivity/service/ns/consumer/ConsumerService.java b/service/notification/android/notification-service/src/main/java/org/iotivity/service/ns/consumer/ConsumerService.java
index 58bf57a..50e4980 100755
--- a/service/notification/android/notification-service/src/main/java/org/iotivity/service/ns/consumer/ConsumerService.java
+++ b/service/notification/android/notification-service/src/main/java/org/iotivity/service/ns/consumer/ConsumerService.java
@@ -25,15 +25,15 @@ import org.iotivity.service.ns.common.*;
 import java.util.Vector;
 
 /**
-  * @class   ConsumerService
-  * @brief   This class provides a set of Java APIs for Notification Consumer.
-  */
-public class ConsumerService
-{
+ *
+ * This class provides a set of Java APIs for Notification ConsumerService.
+ *
+ */
+public class ConsumerService {
+
     private static final String LOG_TAG = "ConsumerService";
 
-    static
-    {
+    static {
         System.loadLibrary("gnustl_shared");
         System.loadLibrary("oc_logger");
         System.loadLibrary("connectivity_abstraction");
@@ -47,74 +47,99 @@ public class ConsumerService
     }
 
     private static ConsumerService instance;
-    static
-    {
+    static {
         instance = new ConsumerService();
     }
 
     /**
-      * API for getting instance of ConsumerService
-      * @return ConsumerService singleton instance created
-      */
-    public static ConsumerService getInstance()
-    {
+     * API for getting instance of ConsumerService
+     *
+     * @return ConsumerService singleton instance created
+     */
+    public static ConsumerService getInstance() {
         return instance;
     }
 
-   /**
-     * Start ConsumerService
-     * @param onProviderDiscoveredListener - OnProviderDiscoveredListener Callback Interface
+    /**
+     * This API will Start ConsumerService
+     *
+     * @param onProviderDiscoveredListener
+     *            OnProviderDiscoveredListener Callback Interface
+     *
+     * @throws NSException
+     *             if the parameter passed is null
      */
-    public void start(
-        OnProviderDiscoveredListener onProviderDiscoveredListener
-    ) throws NSException
-    {
+    public void start(OnProviderDiscoveredListener onProviderDiscoveredListener)
+            throws NSException {
         nativeStart(onProviderDiscoveredListener);
     }
 
     /**
-      * Stop ConsumerService
-      */
-    public void stop() throws NSException
-    {
+     * This API will Stop ConsumerService
+     */
+    public void stop() throws NSException {
         nativeStop();
     }
 
     /**
-      * Request to publish resource to cloud server
-      * @param[in]  serverAddress combined with IP address and port number using delimiter :
-      * @return  result code
-      */
-    public void enableRemoteService(String serverAddress) throws NSException
-    {
+     * Request to publish resource to cloud server
+     *
+     * @param serverAddress
+     *            serverAddress combined with IP address and port number using
+     *            delimiter
+     */
+    public void enableRemoteService(String serverAddress) throws NSException {
         nativeEnableRemoteService(serverAddress);
     }
 
     /**
-      * Request discovery manually
-      */
-    public void rescanProvider() throws NSException
-    {
+     * Request to subscribe to MQ server
+     *
+     * @param servAdd
+     *            servAdd combined with IP address and port number and MQ broker
+     *            uri using delimiter
+     * @param topicName
+     *            the interest Topic name for subscription
+     *
+     * @throws NSException failed to subscribe to MQ server
+     */
+    public void subscribeMQService(String servAdd, String topicName)
+            throws NSException {
+        nativeSubscribeMQService(servAdd, topicName);
+    }
+
+    /**
+     * This API is called to request discovery manually
+     */
+    public void rescanProvider() throws NSException {
         nativeRescanProvider();
     }
 
     /**
-      * Interface to implement callback function to receive provider on discovery
-      */
-    public interface OnProviderDiscoveredListener
-    {
+     * Interface to implement callback function to receive provider on discovery
+     */
+    public interface OnProviderDiscoveredListener {
+
         /**
-          * Callback function to receive provider on discovery
-          * @param provider - Provider object
-          */
+         * Callback function to receive provider on discovery
+         *
+         * @param provider
+         *            Provider object
+         */
         public void onProviderDiscovered(Provider provider);
     }
 
-    private native void nativeStart (
-        OnProviderDiscoveredListener onProviderDiscoveredListener
-    ) throws NSException;
+    private native void nativeStart(
+            OnProviderDiscoveredListener onProviderDiscoveredListener)
+            throws NSException;
 
     private native void nativeStop() throws NSException;
-    private native void nativeEnableRemoteService(String serverAddress) throws NSException;
+
+    private native void nativeEnableRemoteService(String serverAddress)
+            throws NSException;
+
+    private native void nativeSubscribeMQService(String servAdd,
+            String topicName) throws NSException;
+
     private native void nativeRescanProvider() throws NSException;
 }