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

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

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

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

.. java:import:: java.util List

.. java:import:: java.util Map

.. java:import:: java.util UUID

StreamWriter
============

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

.. java:type:: public class StreamWriter

   Class to send messages upstream to TaskMonk

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

.. java:field::  String accessKey
   :outertype: StreamWriter

messageStreamWriter
^^^^^^^^^^^^^^^^^^^

.. java:field::  MessageStreamWriter messageStreamWriter
   :outertype: StreamWriter

queueName
^^^^^^^^^

.. java:field::  String queueName
   :outertype: StreamWriter

Constructors
------------
StreamWriter
^^^^^^^^^^^^

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

Methods
-------
send
^^^^

.. java:method:: public String send(String projectId, String batchId, List<Task> tasks) throws Exception
   :outertype: StreamWriter

   Send a list of new tasks to TaskMonk

   :param projectId:
   :param batchId:
   :param tasks: - Map of key value pairs for the tasks
   :throws Exception:
   :return: A correlation id for the upload