geonode.messaging.producer
==========================

.. py:module:: geonode.messaging.producer


Attributes
----------

.. autoapisummary::

   geonode.messaging.producer.logger
   geonode.messaging.producer.LOCAL_STARTED


Functions
---------

.. autoapisummary::

   geonode.messaging.producer.sync_if_local_memory
   geonode.messaging.producer.send_email_producer
   geonode.messaging.producer.geoserver_upload_dataset
   geonode.messaging.producer.notifications_send
   geonode.messaging.producer.viewing_dataset


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

.. py:data:: logger

.. py:data:: LOCAL_STARTED
   :value: False


.. py:function:: sync_if_local_memory(func, *args, **kwargs)

   Runs locally, synchronous if connection is memory://
   This will create in-memory transport if messaging is
   not configured.

   This allows to run synchronous queue in deployments
   which don't have external broker deployed


.. py:function:: send_email_producer(dataset_uuid, user_id)

.. py:function:: geoserver_upload_dataset(payload)

.. py:function:: notifications_send(payload, created=None)

.. py:function:: viewing_dataset(user, owner, dataset_id)