snews_pt.messages
=================

.. py:module:: snews_pt.messages


Classes
-------

.. autoapisummary::

   snews_pt.messages.Publisher


Functions
---------

.. autoapisummary::

   snews_pt.messages.test


Module Contents
---------------

.. py:class:: Publisher(kafka_topic, auth=True)

   .. py:attribute:: kafka_topic


   .. py:attribute:: auth
      :value: True



   .. py:attribute:: message_queue
      :value: []



   .. py:method:: add_message(message: Union[dict, snews.models.messages.MessageBase], verbose: int = 0) -> None

      This method will add a message to the message queue.

      :param message: observation message.
      :type message: `dict` or snews.messages.MessageBase
      :param verbose: verbosity level. 0: no output, 1: print simple feedback, 2: print message details.
      :type verbose: `int`



   .. py:method:: send(verbose: int = 0) -> None

      This method will send the messages to the Kafka topic.

      :param verbose: verbosity level. 0: no output, 1: print simple feedback, 2: print message details.
      :type verbose: `int`



.. py:function:: test()