geonode.messaging.consumer

Attributes

logger

Classes

Consumer

Functions

_update_dataset_data(body, last_message)
_wait_for_dataset(dataset_id[, num_attempts, wait_seconds])	Blocks execution while the Dataset instance is not found on the database

Module Contents

geonode.messaging.consumer.logger

class geonode.messaging.consumer.Consumer(connection, messages_limit=None)

Bases: kombu.mixins.ConsumerMixin

last_message = None

connection

messages_limit

get_consumers(Consumer, channel)

_check_message_limit()

on_consume_end(connection, channel)

on_message(body, message)

on_email_messages(body, message)

on_geoserver_messages(body, message)

on_notifications_messages(body, message)

on_geoserver_all(body, message)

on_geoserver_catalog(body, message)

on_geoserver_data(body, message)

on_consume_ready(connection, channel, consumers, **kwargs)

on_dataset_viewer(body, message)

geonode.messaging.consumer._update_dataset_data(body, last_message)

geonode.messaging.consumer._wait_for_dataset(dataset_id, num_attempts=5, wait_seconds=1)

Blocks execution while the Dataset instance is not found on the database

This is a workaround for the fact that the geonode.geoserver.signals.geoserver_post_save_local function might try to access the layer’s id parameter before the layer is done being saved in the database.