Contents
========


* `Contents <#contents>`__

  * `EmbSubscriber <#embsubscriber>`__

    * `Prerequisites <#prerequisites>`__
    * `Run the EmbSubscriber <#run-embsubscriber>`__
    * `Run the EmbSubscriber in IPC mode <#run-embsubscriber-in-ipc-mode>`__

EmbSubscriber
-------------

EmbSubscriber subscribes message coming from the publisher. It subscribes to message bus topic to get the data.

Prerequisites
^^^^^^^^^^^^^


#. 
   EmbSubscriber expects a set of config, interfaces & public private keys to be present in ETCD as a prerequisite.
    To achieve this, ensure an entry for the EmbSubscriber with its relative path from the IEdgeInsights(\ ``[WORK_DIR]/IEdgeInsights/``\ ) directory is set in the time-series.yml file present in build/usecases(\ ``[WORK_DIR]/IEdgeInsights/build/usecases``\ ) directory. 

    For example:

   .. code-block:: sh

           AppName:
           - ConfigMgrAgent
           - Visualizer/multimodal-data-visualization/eii
           - DataStore
           - Kapacitor
           - Telegraf
           - tools/EmbSubscriber

#. 
   After completing the previous prerequisites, execute the following command:

   .. code-block:: sh

         cd [WORKDIR]/IEdgeInsights/build
         python3 builder.py -f usecases/time-series.yml

Run the EmbSubscriber
^^^^^^^^^^^^^^^^^^^^^


#. Refer to the `../README.md </4.0/IEdgeInsights/README.html>`_ to provision, build and run the tool along with the EII Time Series recipe or stack.

Run the EmbSubscriber in IPC mode
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

To run EmbSubscriber in the IPC mode, modify the following interfaces section of the config.json(\ ``[WORK_DIR]/IEdgeInsights/tools/EmbSubscriber/config.json``\ ) file:

.. code-block:: sh

   {
     "config": {},
     "interfaces": {
       "Subscribers": [
         {
           "Name": "TestSub",
           "PublisherAppName": "Telegraf",
           "Type": "zmq_ipc",
           "EndPoint": {
                     "SocketDir": "/EII/sockets",
                     "SocketFile": "telegraf-out"
            },
           "Topics": [
             "*"
           ]
         }
       ]
     }
   }