geonode.messaging.producer

Attributes

logger
LOCAL_STARTED

Functions

sync_if_local_memory(func, *args, **kwargs)	Runs locally, synchronous if connection is memory://
send_email_producer(dataset_uuid, user_id)
geoserver_upload_dataset(payload)
notifications_send(payload[, created])
viewing_dataset(user, owner, dataset_id)

Module Contents

geonode.messaging.producer.logger

geonode.messaging.producer.LOCAL_STARTED = False

geonode.messaging.producer.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

geonode.messaging.producer.send_email_producer(dataset_uuid, user_id)

geonode.messaging.producer.geoserver_upload_dataset(payload)

geonode.messaging.producer.notifications_send(payload, created=None)

geonode.messaging.producer.viewing_dataset(user, owner, dataset_id)