.. java:import:: com.fasterxml.jackson.databind JsonNode

.. java:import:: com.fasterxml.jackson.databind ObjectMapper

.. java:import:: com.microsoft.azure.servicebus.primitives ServiceBusException

.. java:import:: io.taskmonk.entities BatchStatus

.. java:import:: io.taskmonk.entities Task

.. java:import:: io.taskmonk.streaming.azure MessageHandler

.. java:import:: io.taskmonk.streaming.impl MessageStreamListener

.. java:import:: org.slf4j Logger

.. java:import:: org.slf4j LoggerFactory

.. java:import:: java.io IOException

StreamListener
==============

.. java:package:: io.taskmonk.streaming
   :noindex:

.. java:type:: public class StreamListener

   Class to receive update messages from Taskmonk. The client should add a \ :java:ref:`MessageListener`\  to process each of the messages. On completion of message processing, the handler should return a \ :java:ref:`MessageAction`\  which will determine the action to be taken on the message. The semantics provide for Atleast Once processing and so the client might receive duplicate messages.

Fields
------
accessKey
^^^^^^^^^

.. java:field::  String accessKey
   :outertype: StreamListener

messageStreamListener
^^^^^^^^^^^^^^^^^^^^^

.. java:field::  MessageStreamListener messageStreamListener
   :outertype: StreamListener

queueName
^^^^^^^^^

.. java:field::  String queueName
   :outertype: StreamListener

Constructors
------------
StreamListener
^^^^^^^^^^^^^^

.. java:constructor:: public StreamListener(String queueName, String accessKey)
   :outertype: StreamListener

   The queue name and access key are specific to a project and will be provided by Taskmonk

   :param queueName:
   :param accessKey:

Methods
-------
addListener
^^^^^^^^^^^

.. java:method:: public Boolean addListener(MessageListener listener) throws ServiceBusException, InterruptedException
   :outertype: StreamListener

   Add a listener for messages from Taskmonk

   :param listener: \ :java:ref:`MessageListener`\  An implementation to handle messages received
   :throws InterruptedException:
   :throws ServiceBusException:
   :return: true on succesfully adding the listener